(event: {
workspaceId: string;
runId: string;
status: WorkflowRunStatus;
})
| 2332 | } |
| 2333 | |
| 2334 | public async emitWorkflowRunActivity(event: { |
| 2335 | workspaceId: string; |
| 2336 | runId: string; |
| 2337 | status: WorkflowRunStatus; |
| 2338 | }): Promise<void> { |
| 2339 | assert(event.workspaceId.length > 0, "emitWorkflowRunActivity requires workspaceId"); |
| 2340 | assert(event.runId.length > 0, "emitWorkflowRunActivity requires runId"); |
| 2341 | await this.updateActiveWorkflowRunCount(event); |
| 2342 | this.emitWorkspaceActivity( |
| 2343 | event.workspaceId, |
| 2344 | await this.extensionMetadata.getSnapshot(event.workspaceId) |
| 2345 | ); |
| 2346 | } |
| 2347 | |
| 2348 | /** |
| 2349 | * Public so AgentStatusService can broadcast a snapshot it produced after |
no test coverage detected