()
| 88 | } |
| 89 | |
| 90 | func (woc *wfOperationCtx) getWorkflowTaskSet() (*wfv1.WorkflowTaskSet, error) { |
| 91 | taskSet, exists, err := woc.controller.wfTaskSetInformer.Informer().GetIndexer().GetByKey(woc.wf.Namespace + "/" + woc.wf.Name) |
| 92 | if err != nil { |
| 93 | return nil, err |
| 94 | } |
| 95 | if !exists { |
| 96 | return nil, nil |
| 97 | } |
| 98 | return taskSet.(*wfv1.WorkflowTaskSet), nil |
| 99 | } |
| 100 | |
| 101 | func (woc *wfOperationCtx) taskSetReconciliation(ctx context.Context) { |
| 102 | if err := woc.reconcileTaskSet(ctx); err != nil { |
no test coverage detected