diff --git a/Worker/Services/Queue/WorkerQueueService.ts b/Worker/Services/Queue/WorkerQueueService.ts index 68278c4b9a..f55459f239 100644 --- a/Worker/Services/Queue/WorkerQueueService.ts +++ b/Worker/Services/Queue/WorkerQueueService.ts @@ -2,6 +2,10 @@ import Queue, { QueueName } from "Common/Server/Infrastructure/Queue"; export default class WorkerQueueService { public static async getQueueSize(): Promise { - return Queue.getQueueSize(QueueName.Worker); + const [workerSize, workflowSize]: [number, number] = await Promise.all([ + Queue.getQueueSize(QueueName.Worker), + Queue.getQueueSize(QueueName.Workflow), + ]); + return workerSize + workflowSize; } }