( ctx context.Context, taskRecord Task, block TaskBlock, actor ActorContext, release *BlockTaskAndReleaseRunResult, )
| 143 | } |
| 144 | |
| 145 | func (m *Service) dispatchBlockedWake( |
| 146 | ctx context.Context, |
| 147 | taskRecord Task, |
| 148 | block TaskBlock, |
| 149 | actor ActorContext, |
| 150 | release *BlockTaskAndReleaseRunResult, |
| 151 | ) { |
| 152 | runID := "" |
| 153 | executingSessionID := "" |
| 154 | if release != nil { |
| 155 | runID = strings.TrimSpace(release.Run.ID) |
| 156 | executingSessionID = strings.TrimSpace(release.PreviousRun.SessionID) |
| 157 | } |
| 158 | m.dispatchWakeCreator(ctx, &wakeDispatchRequest{ |
| 159 | taskRecord: taskRecord, |
| 160 | runID: runID, |
| 161 | executingSessionID: executingSessionID, |
| 162 | wakeEventID: wakeEventID("blocked", taskRecord.ID, block.ID), |
| 163 | reason: WakeReasonBlocked, |
| 164 | summary: blockedWakeSummary(taskRecord, block), |
| 165 | actor: actor, |
| 166 | }) |
| 167 | } |
| 168 | |
| 169 | func (m *Service) dispatchNeedsAttentionWake( |
| 170 | ctx context.Context, |
no test coverage detected