From 9806cc9bbb38b9be2e76da915afad8bf7ca27d0e Mon Sep 17 00:00:00 2001 From: Volodymyr Stoiko Date: Mon, 9 Mar 2026 18:44:24 +0000 Subject: [PATCH] log waiting for readiness --- cmd/tapRunner.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/cmd/tapRunner.go b/cmd/tapRunner.go index 5a054922f..c92a30040 100644 --- a/cmd/tapRunner.go +++ b/cmd/tapRunner.go @@ -161,6 +161,7 @@ func watchHubPod(ctx context.Context, kubernetesProvider *kubernetes.Provider, c podWatchHelper := kubernetes.NewPodWatchHelper(kubernetesProvider, podExactRegex) eventChan, errorChan := kubernetes.FilteredWatch(ctx, podWatchHelper, []string{config.Config.Tap.Release.Namespace}, podWatchHelper) podReady := false + podRunning := false timeAfter := time.After(120 * time.Second) for { @@ -199,6 +200,9 @@ func watchHubPod(ctx context.Context, kubernetesProvider *kubernetes.Provider, c ready.Hub = true ready.Unlock() log.Info().Str("pod", kubernetes.HubPodName).Msg("Ready.") + } else if modifiedPod.Status.Phase == core.PodRunning && !podRunning { + podRunning = true + log.Info().Str("pod", kubernetes.HubPodName).Msg("Waiting for readiness...") } ready.Lock() @@ -252,6 +256,7 @@ func watchFrontPod(ctx context.Context, kubernetesProvider *kubernetes.Provider, podWatchHelper := kubernetes.NewPodWatchHelper(kubernetesProvider, podExactRegex) eventChan, errorChan := kubernetes.FilteredWatch(ctx, podWatchHelper, []string{config.Config.Tap.Release.Namespace}, podWatchHelper) podReady := false + podRunning := false timeAfter := time.After(120 * time.Second) for { @@ -289,6 +294,9 @@ func watchFrontPod(ctx context.Context, kubernetesProvider *kubernetes.Provider, ready.Front = true ready.Unlock() log.Info().Str("pod", kubernetes.FrontPodName).Msg("Ready.") + } else if modifiedPod.Status.Phase == core.PodRunning && !podRunning { + podRunning = true + log.Info().Str("pod", kubernetes.FrontPodName).Msg("Waiting for readiness...") } ready.Lock()