MCPcopy
hub / github.com/argoproj/argo-workflows / markNodeError

Method markNodeError

workflow/controller/operator.go:3054–3057  ·  view source on GitHub ↗

markNodeError is a convenience method to mark a node with an error and set the message from the error

(ctx context.Context, nodeName string, err error)

Source from the content-addressed store, hash-verified

3052
3053// markNodeError is a convenience method to mark a node with an error and set the message from the error
3054func (woc *wfOperationCtx) markNodeError(ctx context.Context, nodeName string, err error) *wfv1.NodeStatus {
3055 woc.log.WithError(err).WithField("nodeName", nodeName).Error(ctx, "marking node as error")
3056 return woc.markNodePhase(ctx, nodeName, wfv1.NodeError, err.Error())
3057}
3058
3059// markNodePending is a convenience method to mark a node and set the message from the error
3060func (woc *wfOperationCtx) markNodePending(ctx context.Context, nodeName string, err error) *wfv1.NodeStatus {

Callers 11

markTaskSetNodesErrorMethod · 0.95
executeDAGMethod · 0.95
executeDAGTaskMethod · 0.95
operateMethod · 0.95
podReconciliationMethod · 0.95
executeTemplateMethod · 0.95
GetNodeTemplateMethod · 0.95
executeStepsMethod · 0.95
executeStepGroupMethod · 0.95

Calls 4

markNodePhaseMethod · 0.95
ErrorMethod · 0.65
WithFieldMethod · 0.65
WithErrorMethod · 0.65

Tested by

no test coverage detected