Method dispatchTaskRunReleased

internal/task/lease_hooks.go:79–101

(
	ctx context.Context,
	run Run,
	taskRecord Task,
	actor ActorContext,
	previous Run,
	reason string,
)

}

func (m *Service) dispatchTaskRunReleased(
	ctx context.Context,
	run Run,
	taskRecord Task,
	actor ActorContext,
	previous Run,
	reason string,
) {
	contextPayload := m.taskRunHookContext(run, taskRecord, actor)
	contextPayload.ReleaseReason = strings.TrimSpace(reason)
	payload := hookspkg.TaskRunReleasedPayload{
		PayloadBase: hookspkg.PayloadBase{
			Event:     hookspkg.HookTaskRunReleased,
			Timestamp: m.now().UTC(),
		},
		TaskRunContext:    contextPayload,
		PreviousRunStatus: string(previous.Status.Normalize()),
		PreviousSessionID: strings.TrimSpace(previous.SessionID),
		RecoveryReason:    strings.TrimSpace(reason),
	}
	_, err := m.taskHooks.DispatchTaskRunReleased(taskRunObservationHookContext(ctx), payload)
	m.reportTaskRunHookFailure(hookspkg.HookTaskRunReleased, err, run, taskRecord)
}

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