Method failRunRecordWithOptions

internal/task/manager.go:3404–3449

(
	ctx context.Context,
	taskRecord Task,
	run Run,
	failure RunFailure,
	actor ActorContext,
	opts failRunRecordOptions,
)

}

func (m *Service) failRunRecordWithOptions(
	ctx context.Context,
	taskRecord Task,
	run Run,
	failure RunFailure,
	actor ActorContext,
	opts failRunRecordOptions,
) (*Run, error) {
	switch run.Status.Normalize() {
	case TaskRunStatusStarting, TaskRunStatusRunning:
	default:
		return nil, requireRunTransition(run, TaskRunStatusFailed)
	}

	run.Status = TaskRunStatusFailed
	run.Error = failure.Error
	run.Result = nil
	run.ClaimToken = ""
	run.LeaseUntil = time.Time{}
	run.HeartbeatAt = time.Time{}
	run.EndedAt = m.now().UTC()
	if opts.stopTerminalSession {
		if err := m.stopTerminalRunSession(ctx, run, StopReasonFailed); 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, taskEventRunFailed, actor, failedRunPayload{
		Status:     run.Status,
		TaskStatus: reconciledTask.Status,
		Error:      run.Error,
		Metadata:   cloneRawJSON(failure.Metadata),
	}); err != nil {
		return nil, err
	}
	m.dispatchTerminalWake(ctx, reconciledTask, run, actor)

	return &run, nil
}

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