Method dispatchTaskRunLeaseRecovered

internal/task/manager.go:2341–2363

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

}

func (m *Service) dispatchTaskRunLeaseRecovered(
	ctx context.Context,
	run Run,
	taskRecord Task,
	actor ActorContext,
	previousStatus RunStatus,
	previousSessionID string,
	recovery RunBootRecovery,
) {
	payload := hookspkg.TaskRunLeaseRecoveredPayload{
		PayloadBase: hookspkg.PayloadBase{
			Event:     hookspkg.HookTaskRunLeaseRecovered,
			Timestamp: m.now().UTC(),
		},
		TaskRunContext:    m.taskRunHookContext(run, taskRecord, actor),
		PreviousRunStatus: string(previousStatus.Normalize()),
		PreviousSessionID: strings.TrimSpace(previousSessionID),
		RecoveryAction:    string(recovery.Action.Normalize()),
		RecoveryReason:    strings.TrimSpace(recovery.Reason),
	}
	_, err := m.taskHooks.DispatchTaskRunLeaseRecovered(taskRunObservationHookContext(ctx), payload)
	m.reportTaskRunHookFailure(hookspkg.HookTaskRunLeaseRecovered, err, run, taskRecord)
}

func (m *Service) reportTaskRunHookFailure(
	event hookspkg.HookEvent,