zishuo/onepanel
1
0
Fork 0
mirror of https://github.com/onepanelio/onepanel.git synced 2025-10-17 03:00:36 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

clean: removed debugging logging from code

Browse Source
This commit is contained in:
Andrey Melnikov
2020-03-10 11:12:45 -07:00
parent 8cbbf585b3
commit ab938d7312
1 changed files with 0 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/workflow_execution.go
View File

@@ -438,23 +438,16 @@ func (c *Client) WatchWorkflowExecution(namespace, name string) (<-chan *Workflo
select { select {
case next := <-watcher.ResultChan(): case next := <-watcher.ResultChan():
workflow, ok = next.Object.(*wfv1.Workflow) workflow, ok = next.Object.(*wfv1.Workflow)
if !ok {
log.Printf("[info] result unable to typecast to workflow")
}
case <-ticker.C: case <-ticker.C:
} }
if workflow == nil && ok { if workflow == nil && ok {
log.Printf("[info] Workflow == nil && ok. Cont.\n")
continue continue
} }
if workflow == nil && !ok { if workflow == nil && !ok {
log.Printf("[info] Workflow == nil && !ok.\n")
workflow, err = c.ArgoprojV1alpha1().Workflows(namespace).Get(name, metav1.GetOptions{}) workflow, err = c.ArgoprojV1alpha1().Workflows(namespace).Get(name, metav1.GetOptions{})
if err != nil { if err != nil {
log.Printf("[info] Unable to get workflow from argo\n")
log.WithFields(log.Fields{ log.WithFields(log.Fields{
"Namespace": namespace, "Namespace": namespace,
"Name": name, "Name": name,
@@ -463,20 +456,13 @@ func (c *Client) WatchWorkflowExecution(namespace, name string) (<-chan *Workflo
}).Error("Unable to get workflow.") }).Error("Unable to get workflow.")
break break
} else {
log.Printf("[info] Got workflow from argo. %+v.\n", workflow)
} }
if workflow == nil { if workflow == nil {
log.Printf("[info] Workflow == nil. After got from argo.\n")
break break
} }
} }
if workflow == nil {
log.Printf("[info] Workflow == nil before marshal.\n")
}
manifest, err := json.Marshal(workflow) manifest, err := json.Marshal(workflow)
if err != nil { if err != nil {
log.WithFields(log.Fields{ log.WithFields(log.Fields{
@@ -498,12 +484,10 @@ func (c *Client) WatchWorkflowExecution(namespace, name string) (<-chan *Workflo
} }
if !workflow.Status.FinishedAt.IsZero() || !ok { if !workflow.Status.FinishedAt.IsZero() || !ok {
log.Printf("[info] workflow is finished or not ok breaking\n")
break break
} }
} }
log.Printf("[info] closing and stopping\n")
close(workflowWatcher) close(workflowWatcher)
watcher.Stop() watcher.Stop()
ticker.Stop() ticker.Stop()