Fix incorrect node type

argoproj · Jan 10, 2020 · 396faa0 · 396faa0
1 parent d39a6f7
commit 396faa0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/workflow/controller/dag.go b/workflow/controller/dag.go
@@ -204,7 +204,7 @@ func (d *dagContext) hasMoreRetries(node *wfv1.NodeStatus) bool {
 func (woc *wfOperationCtx) executeDAG(nodeName string, tmplCtx *templateresolution.Context, templateScope string, tmpl *wfv1.Template, orgTmpl wfv1.TemplateHolder, boundaryID string) (*wfv1.NodeStatus, error) {
  node := woc.getNodeByName(nodeName)
  if node == nil {
- node = woc.initializeExecutableNode(nodeName, wfv1.NodeTypeSteps, templateScope, tmpl, orgTmpl, boundaryID, wfv1.NodeRunning)
+ node = woc.initializeExecutableNode(nodeName, wfv1.NodeTypeDAG, templateScope, tmpl, orgTmpl, boundaryID, wfv1.NodeRunning)
  }
 
  defer func() {