Method dispatchTaskRunCompleted

internal/task/lease_hooks.go:103–118

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

}

func (m *Service) dispatchTaskRunCompleted(
	ctx context.Context,
	run Run,
	taskRecord Task,
	actor ActorContext,
) {
	payload := hookspkg.TaskRunCompletedPayload{
		PayloadBase: hookspkg.PayloadBase{
			Event:     hookspkg.HookTaskRunCompleted,
			Timestamp: m.now().UTC(),
		},
		TaskRunContext: m.taskRunHookContext(run, taskRecord, actor),
	}
	_, err := m.taskHooks.DispatchTaskRunCompleted(taskRunObservationHookContext(ctx), payload)
	m.reportTaskRunHookFailure(hookspkg.HookTaskRunCompleted, err, run, taskRecord)
}

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