diff --git a/internal/querycoord/task_scheduler_test.go b/internal/querycoord/task_scheduler_test.go index 92c589285a..ffd383531f 100644 --- a/internal/querycoord/task_scheduler_test.go +++ b/internal/querycoord/task_scheduler_test.go @@ -151,7 +151,7 @@ func TestWatchQueryChannel_ClearEtcdInfoAfterAssignedNodeDown(t *testing.T) { } queryCoord.scheduler.Enqueue([]task{testTask}) - time.Sleep(time.Second) + time.Sleep(100 * time.Millisecond) queryCoord.cluster.stopNode(nodeID) for { newActiveTaskIDKeys, _, err := queryCoord.scheduler.client.LoadWithPrefix(activeTaskPrefix) diff --git a/internal/querynode/query_service_test.go b/internal/querynode/query_service_test.go index d368484b73..059a9098ab 100644 --- a/internal/querynode/query_service_test.go +++ b/internal/querynode/query_service_test.go @@ -160,7 +160,7 @@ func TestSearch_Search(t *testing.T) { err = sendSearchRequest(node.queryNodeLoopCtx, DIM) assert.NoError(t, err) - time.Sleep(1 * time.Second) + time.Sleep(100 * time.Millisecond) err = node.Stop() assert.NoError(t, err) @@ -206,7 +206,7 @@ func TestSearch_SearchMultiSegments(t *testing.T) { err = sendSearchRequest(node.queryNodeLoopCtx, DIM) assert.NoError(t, err) - time.Sleep(1 * time.Second) + time.Sleep(100 * time.Millisecond) err = node.Stop() assert.NoError(t, err) diff --git a/internal/rootcoord/proxy_manager_test.go b/internal/rootcoord/proxy_manager_test.go index a8f6792c52..aabae35756 100644 --- a/internal/rootcoord/proxy_manager_test.go +++ b/internal/rootcoord/proxy_manager_test.go @@ -88,7 +88,7 @@ func TestProxyManager(t *testing.T) { _, err = cli.Delete(ctx, k1) assert.Nil(t, err) - time.Sleep(time.Second) + time.Sleep(100 * time.Millisecond) pm.Stop() - time.Sleep(time.Second) + time.Sleep(100 * time.Millisecond) }