Method FailRun

internal/task/manager.go:2154–2177

FailRun marks one starting or running task run as failed and reconciles task state.

(
	ctx context.Context,
	runID string,
	failure RunFailure,
	actor ActorContext,
)

// FailRun marks one starting or running task run as failed and reconciles task state.
func (m *Service) FailRun(
	ctx context.Context,
	runID string,
	failure RunFailure,
	actor ActorContext,
) (*Run, error) {
	if err := requireWriteAuthority(actor); err != nil {
		return nil, err
	}

	normalizedFailure, err := normalizeRunFailure(failure)
	if err != nil {
		return nil, err
	}

	run, taskRecord, err := m.loadRunWithTask(ctx, runID)
	if err != nil {
		return nil, err
	}
	if strings.TrimSpace(run.ClaimTokenHash) != "" {
		return nil, fmt.Errorf("%w: task run %q requires token-fenced failure", ErrInvalidClaimToken, run.ID)
	}
	return m.failRunRecord(ctx, taskRecord, run, normalizedFailure, actor)
}

// CancelRun cancels one non-terminal task run under manager authority.
func (m *Service) CancelRun(