diff --git a/go/test/endtoend/cluster/vtctlclient_process.go b/go/test/endtoend/cluster/vtctlclient_process.go index 3c4941da2c2..4df888a80ab 100644 --- a/go/test/endtoend/cluster/vtctlclient_process.go +++ b/go/test/endtoend/cluster/vtctlclient_process.go @@ -210,7 +210,7 @@ func (vtctlclient *VtctlClientProcess) ExecuteCommandWithOutput(args ...string) log.Infof("Executing vtctlclient with command: %v (attempt %d of %d)", strings.Join(tmpProcess.Args, " "), i, retries) resultByte, err = tmpProcess.CombinedOutput() resultStr = string(resultByte) - if err == nil || !shouldRetry(resultStr) { + if err == nil { break } time.Sleep(retryDelay)