added nodeName as a field

pipekit · May 21, 2024 · d0058e2 · d0058e2
1 parent 63422d4
commit d0058e2
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/workflow/controller/dag.go b/workflow/controller/dag.go
@@ -289,11 +289,10 @@ func (woc *wfOperationCtx) executeDAG(ctx context.Context, nodeName string, tmpl
 
 	hook := &NanoSecondHook{}
 
-	log := woc.log.WithField("workflow", woc.wf.Name)
-
 	myCount := globalExecDAGCount.Load()
-
+	log := woc.log.WithField("workflow", woc.wf.Name)
 	log = log.WithField("DAGExecNum", myCount)
+	log = log.WithField("nodeName", nodeName)
 
 	dagCtx := &dagContext{
 		boundaryName:   nodeName,