markNodePending is a convenience method to mark a node and set the message from the error
(ctx context.Context, nodeName string, err error)
| 3058 | |
| 3059 | // markNodePending is a convenience method to mark a node and set the message from the error |
| 3060 | func (woc *wfOperationCtx) markNodePending(ctx context.Context, nodeName string, err error) *wfv1.NodeStatus { |
| 3061 | woc.log.WithFields(logging.Fields{"nodeName": nodeName, "error": err}).Info(ctx, "marking node as pending") |
| 3062 | return woc.markNodePhase(ctx, nodeName, wfv1.NodePending, err.Error()) // this error message will not change often |
| 3063 | } |
| 3064 | |
| 3065 | // markNodeWaitingForLock is a convenience method to mark that a node is waiting for a lock |
| 3066 | func (woc *wfOperationCtx) markNodeWaitingForLock(ctx context.Context, nodeName string, lockName string, message string) (*wfv1.NodeStatus, error) { |
no test coverage detected