Method approvalAutoEnqueueExecution

internal/task/manager.go:757–801

(
	ctx context.Context,
	approvalTask *Task,
	req ExecutionRequest,
	executionIdempotencyKey string,
	actor ActorContext,
)

}

func (m *Service) approvalAutoEnqueueExecution(
	ctx context.Context,
	approvalTask *Task,
	req ExecutionRequest,
	executionIdempotencyKey string,
	actor ActorContext,
) (*Execution, bool, error) {
	if approvalTask == nil ||
		!approvalTask.AutoEnqueueOnReady ||
		approvalTask.Status.Normalize() != TaskStatusReady {
		return nil, false, nil
	}
	trigger := autoEnqueueTrigger{
		Kind: autoEnqueueTriggerApprovalGranted,
		Ref:  approvalTask.ID,
	}
	run, err := m.EnqueueRun(ctx, EnqueueRun{
		TaskID:         approvalTask.ID,
		IdempotencyKey: trigger.idempotencyKey(approvalTask.ID),
		NetworkChannel: req.NetworkChannel,
		Metadata:       req.Metadata,
	}, actor)
	if err != nil {
		return nil, false, err
	}
	if err := m.saveApprovalAutoEnqueueIdempotencyAlias(
		ctx,
		approvalTask.ID,
		run.ID,
		executionIdempotencyKey,
		actor,
	); err != nil {
		return nil, false, err
	}
	taskRecord, err := m.store.GetTask(ctx, run.TaskID)
	if err != nil {
		return nil, false, err
	}
	m.recordAutoEnqueueTriggered(ctx, *approvalTask, run, trigger, actor)
	return &Execution{
		Task:   taskRecord,
		Run:    *run,
		Action: ExecutionActionApproval,
	}, true, nil
}

func (m *Service) saveApprovalAutoEnqueueIdempotencyAlias(
	ctx context.Context,