From bfc7f5882e8dd2533c4c7d0e037e17e723feb639 Mon Sep 17 00:00:00 2001 From: Nicolas Date: Fri, 12 Jul 2024 19:57:12 -0400 Subject: [PATCH] Update index.ts --- apps/api/src/services/alerts/index.ts | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/apps/api/src/services/alerts/index.ts b/apps/api/src/services/alerts/index.ts index b388b1ee..1cfb5906 100644 --- a/apps/api/src/services/alerts/index.ts +++ b/apps/api/src/services/alerts/index.ts @@ -35,7 +35,9 @@ export async function checkAlerts() { const checkWaitingQueue = async () => { const webScraperQueue = getWebScraperQueue(); const waitingJobs = await webScraperQueue.getWaitingCount(); - if (waitingJobs > Number(process.env.ALERT_NUM_WAITING_JOBS)) { + const paused = await webScraperQueue.getPausedCount(); + + if (waitingJobs !== paused && waitingJobs > Number(process.env.ALERT_NUM_WAITING_JOBS)) { console.warn( `Alert: Number of waiting jobs is over ${process.env.ALERT_NUM_WAITING_JOBS}. Current waiting jobs: ${waitingJobs}.` );