requeue this workflow onto the workqueue for later processing
(afterDuration time.Duration)
| 967 | |
| 968 | // requeue this workflow onto the workqueue for later processing |
| 969 | func (woc *wfOperationCtx) requeueAfter(afterDuration time.Duration) { |
| 970 | key, _ := cache.MetaNamespaceKeyFunc(woc.wf) |
| 971 | woc.controller.wfQueue.AddAfter(key, afterDuration) |
| 972 | } |
| 973 | |
| 974 | func (woc *wfOperationCtx) requeue() { |
| 975 | key, _ := cache.MetaNamespaceKeyFunc(woc.wf) |
no outgoing calls
no test coverage detected