diff --git a/logger/argo_logs.go b/logger/argo_logs.go index 03ff048..64fd6b8 100644 --- a/logger/argo_logs.go +++ b/logger/argo_logs.go @@ -125,7 +125,7 @@ func LogKubernetesArgo(wfName string, namespace string, watcher watch.Interface) continue } if len(wf.Status.Nodes) == 0 { - wfl.Debug().Msg("No node status yet") // The first output of the channel doesn't contain Nodes so we skip it + wfl.Info().Msg("No node status yet") // The first output of the channel doesn't contain Nodes so we skip it continue } diff --git a/main.go b/main.go index cbea62f..721a23b 100644 --- a/main.go +++ b/main.go @@ -67,14 +67,14 @@ func main() { logger = u.GetLogger() logger.Debug().Msg("Loki URL : " + conf.GetConfig().LokiURL) - logger.Debug().Msg("Workflow executed : " + conf.GetConfig().ExecutionID) + logger.Info().Msg("Workflow executed : " + conf.GetConfig().ExecutionID) exec := u.GetExecution(conf.GetConfig().ExecutionID) if exec == nil { logger.Fatal().Msg("Could not retrieve workflow ID from execution ID " + conf.GetConfig().ExecutionID + " on peer " + conf.GetConfig().PeerID) } conf.GetConfig().WorkflowID = exec.WorkflowID - logger.Debug().Msg("Starting construction of yaml argo for workflow :" + exec.WorkflowID) + logger.Info().Msg("Starting construction of yaml argo for workflow :" + exec.WorkflowID) if _, err := os.Stat("./argo_workflows/"); os.IsNotExist(err) { os.Mkdir("./argo_workflows/", 0755) @@ -102,9 +102,6 @@ func main() { workflowName = getContainerName(argoFilePath) - wf_logger := u.GetWFLogger(workflowName) - wf_logger.Debug().Msg("Testing argo name") - if conf.GetConfig().KubeHost == "" { // Not in a k8s environment, get conf from parameters logger.Info().Msg("Executes outside of k8s") diff --git a/tools/kubernetes.go b/tools/kubernetes.go index d46e45d..ae7fe14 100644 --- a/tools/kubernetes.go +++ b/tools/kubernetes.go @@ -116,8 +116,6 @@ func (k *KubernetesTools) CreateAccessSecret(ns string, login string, password s } func (k *KubernetesTools) GetArgoWatch(executionId string, wfName string) (watch.Interface, error){ - wfl := utils.GetWFLogger("") - wfl.Debug().Msg("Starting argo watch with argo lib") options := metav1.ListOptions{FieldSelector: "metadata.name=oc-monitor-"+wfName} watcher, err := k.VersionedSet.ArgoprojV1alpha1().Workflows(executionId).Watch(context.Background(), options)