diff --git a/logger/argo_logs.go b/logger/argo_logs.go index 9b59ba6..e28b950 100644 --- a/logger/argo_logs.go +++ b/logger/argo_logs.go @@ -112,7 +112,8 @@ func LogKubernetesArgo(wfName string, executionID string, watcher watch.Interfac var node wfv1.NodeStatus wfl := utils.GetWFLogger("") - + wfl.Debug().Msg("Starting to log " + wfName) + for event := range (watcher.ResultChan()) { wf, ok := event.Object.(*wfv1.Workflow) if !ok {