( event hookspkg.HookEvent, err error, run Run, taskRecord Task, )
| 2363 | } |
| 2364 | |
| 2365 | func (m *Service) reportTaskRunHookFailure( |
| 2366 | event hookspkg.HookEvent, |
| 2367 | err error, |
| 2368 | run Run, |
| 2369 | taskRecord Task, |
| 2370 | ) { |
| 2371 | if err == nil { |
| 2372 | return |
| 2373 | } |
| 2374 | slog.Error( |
| 2375 | "task: task-run lifecycle hook failed after committed mutation", |
| 2376 | "error", err, |
| 2377 | "hook_event", event, |
| 2378 | "task_id", taskRecord.ID, |
| 2379 | "run_id", run.ID, |
| 2380 | "run_status", run.Status, |
| 2381 | ) |
| 2382 | } |
| 2383 | |
| 2384 | func (m *Service) taskRunHookContext(run Run, taskRecord Task, actor ActorContext) hookspkg.TaskRunContext { |
| 2385 | coordinationChannelID := taskRunCoordinationChannelID(run) |
no test coverage detected