From 7c913bec0e0a2f18660ae9a52e89cbdd168a6c26 Mon Sep 17 00:00:00 2001 From: pb Date: Fri, 23 May 2025 17:56:30 +0200 Subject: [PATCH] small tweaks --- logger/argo_logs.go | 2 ++ main.go | 4 +++- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/logger/argo_logs.go b/logger/argo_logs.go index 547ab0e..03ff048 100644 --- a/logger/argo_logs.go +++ b/logger/argo_logs.go @@ -179,6 +179,7 @@ func LogKubernetesArgo(wfName string, namespace string, watcher watch.Interface) if node.Phase.Completed() { wfl.Info().Msg(wfName + " worflow completed") wg.Wait() + wfl.Info().Msg(wfName + " exiting") break } if node.Phase.FailedOrError() { @@ -205,6 +206,7 @@ func retrieveCondition(wf *wfv1.Workflow) (c Conditions) { // Function needed to be executed as a go thread func logKubernetesPods(executionId string, wfName string,podName string, logger zerolog.Logger, wg *sync.WaitGroup){ + defer wg.Done() s := strings.Split(podName, ".") name := s[0] + "-" + s[1] diff --git a/main.go b/main.go index 01449fd..cbea62f 100644 --- a/main.go +++ b/main.go @@ -126,7 +126,7 @@ func executeInside(execID string, ns string, argo_file_path string) { } name, err := t.CreateArgoWorkflow(argo_file_path, ns) - _ = name + // _ = name if err != nil { logger.Error().Msg("Could not create argo workflow : " + err.Error()) logger.Info().Msg(fmt.Sprint("CA :" + conf.GetConfig().KubeCA)) @@ -143,6 +143,8 @@ func executeInside(execID string, ns string, argo_file_path string) { if err != nil { logger.Error().Msg("Could not log workflow : " + err.Error()) } + + logger.Info().Msg("Finished, exiting...") } }