github/oneuptime
1
1
Fork 0
mirror of https://github.com/OneUptime/oneuptime.git synced 2026-04-06 00:32:12 +02:00
Code Issues 193 Packages Projects Releases Wiki Activity

fix: Update getQueueSize method to return combined queue sizes for worker and workflow

Browse Source
This commit is contained in:
Nawaz Dhandala
2026-03-04 14:02:39 +00:00
parent 75f456089b
commit cf26ce657e
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
Worker/Services/Queue/WorkerQueueService.ts
View File

@@ -2,6 +2,10 @@ import Queue, { QueueName } from "Common/Server/Infrastructure/Queue";
export default class WorkerQueueService {
public static async getQueueSize(): Promise<number> {
return Queue.getQueueSize(QueueName.Worker);
const [workerSize, workflowSize]: [number, number] = await Promise.all([
Queue.getQueueSize(QueueName.Worker),
Queue.getQueueSize(QueueName.Workflow),
]);
return workerSize + workflowSize;
}
}