Skip to content

Commit 3966752

Browse files
committed
feat(run-engine): expose the per-gate queued counts on the engine
1 parent 3ef427e commit 3966752

1 file changed

Lines changed: 7 additions & 0 deletions

File tree

  • internal-packages/run-engine/src/engine

‎internal-packages/run-engine/src/engine/index.ts‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1762,6 +1762,13 @@ export class RunEngine {
17621762
return this.runQueue.totalConcurrencyLimitsOfQueues(environment, queues);
17631763
}
17641764

1765+
async gateQueuedCountOfQueues(
1766+
environment: MinimalAuthenticatedEnvironment,
1767+
queues: string[]
1768+
): Promise<Record<string, number>> {
1769+
return this.runQueue.gateQueuedCountOfQueues(environment, queues);
1770+
}
1771+
17651772
async concurrencyKeyBreakdown(
17661773
environment: MinimalAuthenticatedEnvironment,
17671774
queue: string,

0 commit comments

Comments
 (0)