MCPcopy Create free account
hub / github.com/compozy/agh / dispatchBlockedWake

Method dispatchBlockedWake

internal/task/wake.go:145–167  ·  view source on GitHub ↗
(
	ctx context.Context,
	taskRecord Task,
	block TaskBlock,
	actor ActorContext,
	release *BlockTaskAndReleaseRunResult,
)

Source from the content-addressed store, hash-verified

143}
144
145func (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
169func (m *Service) dispatchNeedsAttentionWake(
170 ctx context.Context,

Callers 1

BlockTaskMethod · 0.95

Calls 3

dispatchWakeCreatorMethod · 0.95
wakeEventIDFunction · 0.85
blockedWakeSummaryFunction · 0.85

Tested by

no test coverage detected