Method dispatchTaskRunEnqueued

internal/task/manager.go:2268–2285

(
	ctx context.Context,
	run Run,
	taskRecord Task,
	actor ActorContext,
	idempotencyKey string,
)

}

func (m *Service) dispatchTaskRunEnqueued(
	ctx context.Context,
	run Run,
	taskRecord Task,
	actor ActorContext,
	idempotencyKey string,
) {
	payload := hookspkg.TaskRunEnqueuedPayload{
		PayloadBase: hookspkg.PayloadBase{
			Event:     hookspkg.HookTaskRunEnqueued,
			Timestamp: m.now().UTC(),
		},
		TaskRunContext: m.taskRunHookContext(run, taskRecord, actor),
		IdempotencyKey: strings.TrimSpace(idempotencyKey),
	}
	_, err := m.taskHooks.DispatchTaskRunEnqueued(taskRunObservationHookContext(ctx), payload)
	m.reportTaskRunHookFailure(hookspkg.HookTaskRunEnqueued, err, run, taskRecord)
}

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