Method recoverRunByRequeue

internal/task/manager.go:1351–1401

(
	ctx context.Context,
	taskRecord Task,
	run Run,
	recovery RunBootRecovery,
	actor ActorContext,
	previousStatus RunStatus,
	previousSessionID string,
)

}

func (m *Service) recoverRunByRequeue(
	ctx context.Context,
	taskRecord Task,
	run Run,
	recovery RunBootRecovery,
	actor ActorContext,
	previousStatus RunStatus,
	previousSessionID string,
) (*Run, error) {
	if previousStatus != TaskRunStatusClaimed {
		return nil, invalidRunRecoveryTransition(run, previousStatus, recovery.Action)
	}

	run.Status = TaskRunStatusQueued
	run.ClaimedBy = nil
	run.ClaimedAt = time.Time{}
	run.SessionID = ""
	run.ClaimToken = ""
	run.ClaimTokenHash = ""
	run.LeaseUntil = time.Time{}
	run.HeartbeatAt = time.Time{}
	run.StartedAt = time.Time{}
	run.EndedAt = time.Time{}
	run.Error = ""
	run.Result = nil
	if err := m.store.UpdateTaskRun(ctx, run); err != nil {
		return nil, err
	}
	reconciledTask, err := m.recordRecoveredRun(
		ctx,
		taskRecord.ID,
		run,
		recovery,
		actor,
		previousStatus,
		previousSessionID,
	)
	if err != nil {
		return nil, err
	}
	m.dispatchTaskRunLeaseRecovered(
		ctx,
		run,
		reconciledTask,
		actor,
		previousStatus,
		previousSessionID,
		recovery,
	)
	return &run, nil
}

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