| 712 | } |
| 713 | |
| 714 | func (m *Service) dispatchTaskRecovered( |
| 715 | ctx context.Context, |
| 716 | taskRecord Task, |
| 717 | actor ActorContext, |
| 718 | note string, |
| 719 | at time.Time, |
| 720 | ) { |
| 721 | payload := hookspkg.TaskRecoveredPayload{ |
| 722 | PayloadBase: hookspkg.PayloadBase{ |
| 723 | Event: hookspkg.HookTaskRecovered, |
| 724 | Timestamp: m.now().UTC(), |
| 725 | }, |
| 726 | TaskContext: m.taskHookContext(taskRecord, actor, nil), |
| 727 | Note: redactTaskSecretText(strings.TrimSpace(note)), |
| 728 | At: at, |
| 729 | } |
| 730 | _, err := m.taskHooks.DispatchTaskRecovered(taskRunObservationHookContext(ctx), payload) |
| 731 | m.reportTaskHookFailure(hookspkg.HookTaskRecovered, err, taskRecord) |
| 732 | } |
| 733 | |
| 734 | func (m *Service) taskHookContext( |
| 735 | taskRecord Task, |