small tweaks

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]