Method dispatchTaskRunPreClaim

internal/task/manager.go:2287–2321

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

}

func (m *Service) dispatchTaskRunPreClaim(
	ctx context.Context,
	run Run,
	taskRecord Task,
	actor ActorContext,
) error {
	contextPayload := m.taskRunHookContext(run, taskRecord, actor)
	payload := hookspkg.TaskRunPreClaimPayload{
		PayloadBase: hookspkg.PayloadBase{
			Event:     hookspkg.HookTaskRunPreClaim,
			Timestamp: m.now().UTC(),
		},
		TaskRunContext: contextPayload,
		Criteria: hookspkg.TaskRunClaimCriteria{
			WorkspaceID:           contextPayload.WorkspaceID,
			ClaimerSessionID:      taskRunHookClaimerSessionID(run, actor),
			AgentName:             contextPayload.AgentName,
			RequiredCapabilities:  append([]string(nil), run.RequiredCapabilities...),
			PriorityMin:           taskPriorityMin(taskRecord.Priority),
			CoordinationChannelID: contextPayload.CoordinationChannelID,
		},
	}
	result, err := m.taskHooks.DispatchTaskRunPreClaim(ctx, payload)
	if err != nil {
		return err
	}
	if result.Denied {
		reason := strings.TrimSpace(result.DenyReason)
		if reason == "" {
			reason = "task run claim denied by hook"
		}
		return fmt.Errorf("%w: %s", ErrPermissionDenied, reason)
	}
	return nil
}

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