From 1d24188a0219179c6ebe7d88014ce4269d2aa961 Mon Sep 17 00:00:00 2001 From: RamiBerm Date: Tue, 20 Jul 2021 09:58:08 +0300 Subject: [PATCH] Update tapRunner.go --- cli/cmd/tapRunner.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/cli/cmd/tapRunner.go b/cli/cmd/tapRunner.go index de2691397..26bec8fc2 100644 --- a/cli/cmd/tapRunner.go +++ b/cli/cmd/tapRunner.go @@ -230,6 +230,7 @@ func portForwardApiPod(ctx context.Context, kubernetesProvider *kubernetes.Provi podExactRegex := regexp.MustCompile(fmt.Sprintf("^%s$", mizu.AggregatorPodName)) added, modified, removed, errorChan := kubernetes.FilteredWatch(ctx, kubernetesProvider.GetPodWatcher(ctx, mizu.ResourcesNamespace), podExactRegex) isPodReady := false + timeAfter := time.After(25 * time.Second) for { select { case <-added: @@ -269,7 +270,7 @@ func portForwardApiPod(ctx context.Context, kubernetesProvider *kubernetes.Provi } } - case <-time.After(25 * time.Second): + case <- timeAfter: if !isPodReady { fmt.Printf("error: %s pod was not ready in time", mizu.AggregatorPodName) cancel()