diff --git a/tools/kubernetes.go b/tools/kubernetes.go index df68cc7..c5142c8 100644 --- a/tools/kubernetes.go +++ b/tools/kubernetes.go @@ -64,7 +64,7 @@ func (k *KubernetesTools) LogWorkflow(execID string, namespace string, workflowN if exec == nil { return errors.New("Could not retrieve workflow ID from execution ID " + execID) } - if exec.State == enum.FAILURE || exec.State == enum.SUCCESS { + if exec.State != enum.SCHEDULED { return nil } k.logWorkflow(namespace, workflowName, argoFilePath, stepMax, current_watch, previous_watch, argoLogs, seen, logFunc)