Method dispatchTaskRunPostClaim

internal/task/manager.go:2323–2339

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

}

func (m *Service) dispatchTaskRunPostClaim(
	ctx context.Context,
	run Run,
	taskRecord Task,
	actor ActorContext,
) {
	payload := hookspkg.TaskRunPostClaimPayload{
		PayloadBase: hookspkg.PayloadBase{
			Event:     hookspkg.HookTaskRunPostClaim,
			Timestamp: m.now().UTC(),
		},
		TaskRunContext: m.taskRunHookContext(run, taskRecord, actor),
		ClaimedAt:      run.ClaimedAt,
	}
	_, err := m.taskHooks.DispatchTaskRunPostClaim(taskRunObservationHookContext(ctx), payload)
	m.reportTaskRunHookFailure(hookspkg.HookTaskRunPostClaim, err, run, taskRecord)
}

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