diff --git a/integration/cluster.go b/integration/cluster.go index 0b4114853ec5..0b3e6e8ab595 100644 --- a/integration/cluster.go +++ b/integration/cluster.go @@ -387,7 +387,7 @@ func (c *cluster) waitLeader(t *testing.T, membs []*member) int { // ensure leader is up via linearizable get for { - ctx, cancel := context.WithTimeout(context.Background(), 10*tickDuration) + ctx, cancel := context.WithTimeout(context.Background(), 10*tickDuration+time.Second) _, err := kapi.Get(ctx, "0", &client.GetOptions{Quorum: true}) cancel() if err == nil || strings.Contains(err.Error(), "Key not found") {