Method CompleteRun

internal/task/manager.go:2097–2151

CompleteRun marks one running task run as completed and reconciles task state.

(
	ctx context.Context,
	runID string,
	result RunResult,
	actor ActorContext,
)

// CompleteRun marks one running task run as completed and reconciles task state.
func (m *Service) CompleteRun(
	ctx context.Context,
	runID string,
	result RunResult,
	actor ActorContext,
) (*Run, error) {
	if err := requireWriteAuthority(actor); err != nil {
		return nil, err
	}

	normalizedResult, err := normalizeRunResult(result)
	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 completion", ErrInvalidClaimToken, run.ID)
	}
	if err := requireRunTransition(run, TaskRunStatusCompleted); err != nil {
		return nil, err
	}

	run.Status = TaskRunStatusCompleted
	run.Result = cloneRawJSON(normalizedResult.Value)
	run.Error = ""
	run.ClaimToken = ""
	run.LeaseUntil = time.Time{}
	run.HeartbeatAt = time.Time{}
	run.EndedAt = m.now().UTC()
	if err := m.stopTerminalRunSession(ctx, run, StopReasonCompleted); err != nil {
		return nil, err
	}
	if err := m.store.UpdateTaskRun(ctx, run); err != nil {
		return nil, err
	}

	reconciledTask, err := m.reconcileTaskCascade(ctx, taskRecord.ID)
	if err != nil {
		return nil, err
	}
	if err := m.recordTaskEvent(ctx, run.TaskID, run.ID, taskEventRunCompleted, actor, completedRunPayload{
		Status:     run.Status,
		TaskStatus: reconciledTask.Status,
		Result:     cloneRawJSON(run.Result),
	}); err != nil {
		return nil, err
	}
	m.dispatchTerminalWake(ctx, reconciledTask, run, actor)

	return &run, nil
}

// FailRun marks one starting or running task run as failed and reconciles task state.
func (m *Service) FailRun(