Function newWorkflowOperationCtx

workflow/controller/operator.go:151–186

newWorkflowOperationCtx creates and initializes a new wfOperationCtx object.

(ctx context.Context, wf *wfv1.Workflow, wfc *WorkflowController)

// newWorkflowOperationCtx creates and initializes a new wfOperationCtx object.
func newWorkflowOperationCtx(ctx context.Context, wf *wfv1.Workflow, wfc *WorkflowController) *wfOperationCtx {
	// NEVER modify objects from the store. It's a read-only, local cache.
	// You can use DeepCopy() to make a deep copy of original object and modify this copy
	// Or create a copy manually for better performance
	wfCopy := wf.DeepCopyObject().(*wfv1.Workflow)

	slogger := logging.RequireLoggerFromContext(ctx)

	woc := wfOperationCtx{
		wf:      wfCopy,
		orig:    wf,
		execWf:  wfCopy,
		updated: false,
		log: slogger.WithFields(logging.Fields{
			"workflow":  wf.Name,
			"namespace": wf.Namespace,
		}),
		controller:               wfc,
		globalParams:             make(map[string]string),
		volumes:                  wf.Spec.DeepCopy().Volumes,
		deadline:                 time.Now().UTC().Add(maxOperationTime),
		eventRecorder:            wfc.eventRecorderManager.Get(ctx, wf.Namespace),
		preExecutionNodeStatuses: make(map[string]wfv1.NodeStatus),
		taskSet:                  make(map[string]wfv1.Template),
		currentStackDepth:        0,
	}

	if woc.wf.Status.Nodes == nil {
		woc.wf.Status.Nodes = make(map[string]wfv1.NodeStatus)
	}

	if woc.wf.Status.StoredTemplates == nil {
		woc.wf.Status.StoredTemplates = make(map[string]wfv1.Template)
	}
	return &woc
}

// operate is the main operator logic of a workflow. It evaluates the current state of the workflow,
// and its pods and decides how to proceed down the execution path.