Method activationForRun

internal/daemon/task_role_runtime.go:221–263

(
	ctx context.Context,
	taskRecord taskpkg.Task,
	run taskpkg.Run,
)

}

func (r *taskRoleRuntime) activationForRun(
	ctx context.Context,
	taskRecord taskpkg.Task,
	run taskpkg.Run,
) (taskRoleActivation, bool, error) {
	if run.Status.Normalize() != taskpkg.TaskRunStatusQueued {
		return taskRoleActivation{}, false, nil
	}
	switch taskRecord.Status.Normalize() {
	case taskpkg.TaskStatusDraft, taskpkg.TaskStatusBlocked, taskpkg.TaskStatusCanceled:
		return taskRoleActivation{}, false, nil
	default:
	}
	agentName, provider, model, profile, ok, err := r.workerTargetForRun(ctx, taskRecord)
	if err != nil || !ok {
		return taskRoleActivation{}, false, err
	}
	if agentName == "" {
		return taskRoleActivation{}, false, nil
	}

	activation := taskRoleActivation{
		TaskID:      strings.TrimSpace(taskRecord.ID),
		RunID:       strings.TrimSpace(run.ID),
		Scope:       taskRecord.Scope.Normalize(),
		WorkspaceID: strings.TrimSpace(taskRecord.WorkspaceID),
		AgentName:   agentName,
		Provider:    provider,
		Model:       model,
		Channel:     taskRunSessionChannel(run),
		Title:       strings.TrimSpace(taskRecord.Title),
		Profile:     profile,
		Capabilities: append(
			append([]string(nil), run.RequiredCapabilities...),
			profileRequiredWorkerCapabilities(profile)...,
		),
	}
	applyTaskRoleDesignation(&activation, run)
	if err := r.applyActivationScope(&activation, taskRecord.ID); err != nil {
		return taskRoleActivation{}, false, err
	}
	return activation, true, nil
}

func (r *taskRoleRuntime) workerTargetForRun(
	ctx context.Context,