(server: RuntimeServer | undefined)
| 189 | } |
| 190 | |
| 191 | function notifyWorkingTasks(server: RuntimeServer | undefined): void { |
| 192 | if (!server) return |
| 193 | publishOpenADECompanionEvent(server, { |
| 194 | type: "working_tasks", |
| 195 | taskIds: server.supervisor |
| 196 | .list({ ownerType: "openade-task" }) |
| 197 | .filter((runtime) => runtime.scope.ownerId && (runtime.status === "starting" || runtime.status === "running")) |
| 198 | .map((runtime) => runtime.scope.ownerId as string), |
| 199 | at: new Date().toISOString(), |
| 200 | }) |
| 201 | } |
| 202 | |
| 203 | async function reconcileCheckpointedOpenADEActionEvents({ |
| 204 | server, |
no test coverage detected