diff --git a/pkg/orchestrator/batch_test.go b/pkg/orchestrator/batch_test.go index beb88e70629..352b422128c 100644 --- a/pkg/orchestrator/batch_test.go +++ b/pkg/orchestrator/batch_test.go @@ -90,7 +90,10 @@ func TestGetBatchResponse(t *testing.T) { for i := 0; i < 5; i++ { for j := 0; j < patchSize; j++ { time.Sleep(10 * time.Millisecond) - cli.Put(ctx, prefix+fmt.Sprintf("/key%d", j), "abc") + _, err := cli.Put(ctx, prefix+fmt.Sprintf("/key%d", j), "abc") + if err == nil || err.Error() == "etcdserver: request timed out" { + continue + } } } }()