diff --git a/pkg/cluster/managed.go b/pkg/cluster/managed.go index f3065cf1e1..dc206ff8c3 100644 --- a/pkg/cluster/managed.go +++ b/pkg/cluster/managed.go @@ -136,7 +136,7 @@ func (c *Cluster) setupEtcdProxy(ctx context.Context, etcdProxy etcd.Proxy) { return } // We use Poll here instead of Until because we want to wait the interval before running the function. - go wait.PollUntilContextCancel(ctx, 30*time.Second, true, func(ctx context.Context) (bool, error) { + go wait.PollUntilContextCancel(ctx, 30*time.Second, false, func(ctx context.Context) (bool, error) { clientURLs, err := c.managedDB.GetMembersClientURLs(ctx) if err != nil { logrus.Warnf("Failed to get etcd ClientURLs: %v", err)