Method RecoverRunOnBoot

internal/task/manager.go:2206–2266

RecoverRunOnBoot applies one daemon-owned recovery decision to a non-terminal run discovered during startup reconciliation.

(
	ctx context.Context,
	runID string,
	recovery RunBootRecovery,
	actor ActorContext,
)

// RecoverRunOnBoot applies one daemon-owned recovery decision to a non-terminal
// run discovered during startup reconciliation.
func (m *Service) RecoverRunOnBoot(
	ctx context.Context,
	runID string,
	recovery RunBootRecovery,
	actor ActorContext,
) (*Run, error) {
	if err := requireWriteAuthority(actor); err != nil {
		return nil, err
	}

	normalizedRecovery, err := normalizeRunBootRecovery(recovery)
	if err != nil {
		return nil, err
	}

	run, taskRecord, err := m.loadRunWithTask(ctx, runID)
	if err != nil {
		return nil, err
	}

	previousStatus := run.Status.Normalize()
	previousSessionID := strings.TrimSpace(run.SessionID)
	switch normalizedRecovery.Action.Normalize() {
	case RunBootRecoveryRequeue:
		return m.recoverRunByRequeue(
			ctx,
			taskRecord,
			run,
			normalizedRecovery,
			actor,
			previousStatus,
			previousSessionID,
		)
	case RunBootRecoveryMarkRunning:
		return m.recoverRunByMarkRunning(
			ctx,
			taskRecord,
			run,
			normalizedRecovery,
			actor,
			previousStatus,
			previousSessionID,
		)
	case RunBootRecoveryFail:
		return m.recoverRunByFailure(
			ctx,
			taskRecord,
			run,
			normalizedRecovery,
			actor,
			previousStatus,
			previousSessionID,
		)
	default:
		return nil, fmt.Errorf(
			"%w: run boot recovery action %q is not supported",
			ErrValidation,
			normalizedRecovery.Action,