()
| 972 | } |
| 973 | |
| 974 | func (woc *wfOperationCtx) requeue() { |
| 975 | key, _ := cache.MetaNamespaceKeyFunc(woc.wf) |
| 976 | woc.controller.wfQueue.AddRateLimited(key) |
| 977 | } |
| 978 | |
| 979 | // processNodeRetries updates the retry node state based on the child node state and the retry strategy and returns the node. |
| 980 | func (woc *wfOperationCtx) processNodeRetries(ctx context.Context, node *wfv1.NodeStatus, retryStrategy wfv1.RetryStrategy, opts *executeTemplateOpts) (*wfv1.NodeStatus, bool, error) { |
no outgoing calls
no test coverage detected