From b44358af0757c4dd0ac875c0b5762dd59f0f4b15 Mon Sep 17 00:00:00 2001 From: Nicolas Date: Thu, 30 Jan 2025 13:30:49 -0300 Subject: [PATCH] Update queue-jobs.ts --- apps/api/src/services/queue-jobs.ts | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/apps/api/src/services/queue-jobs.ts b/apps/api/src/services/queue-jobs.ts index a6c367f71..86c232af4 100644 --- a/apps/api/src/services/queue-jobs.ts +++ b/apps/api/src/services/queue-jobs.ts @@ -83,9 +83,9 @@ async function addScrapeJobRaw( // No need to 2x as if there are more than the max concurrency in the concurrency queue, it is already 2x if(concurrencyQueueJobs > maxConcurrency) { logger.info("Concurrency limited 2x (single) - ", "Concurrency queue jobs: ", concurrencyQueueJobs, "Max concurrency: ", maxConcurrency); - sendNotificationWithCustomDays(webScraperOptions.team_id, NotificationType.CONCURRENCY_LIMIT_REACHED, 10, false).catch((error) => { - logger.error("Error sending notification (concurrency limit reached): ", error); - }); + // sendNotificationWithCustomDays(webScraperOptions.team_id, NotificationType.CONCURRENCY_LIMIT_REACHED, 10, false).catch((error) => { + // logger.error("Error sending notification (concurrency limit reached): ", error); + // }); } await _addScrapeJobToConcurrencyQueue( @@ -172,9 +172,9 @@ export async function addScrapeJobs( // equals 2x the max concurrency if(addToCQ.length > maxConcurrency) { logger.info("Concurrency limited 2x (multiple) - ", "Concurrency queue jobs: ", addToCQ.length, "Max concurrency: ", maxConcurrency); - sendNotificationWithCustomDays(jobs[0].data.team_id, NotificationType.CONCURRENCY_LIMIT_REACHED, 10, false).catch((error) => { - logger.error("Error sending notification (concurrency limit reached): ", error); - }); + // sendNotificationWithCustomDays(jobs[0].data.team_id, NotificationType.CONCURRENCY_LIMIT_REACHED, 10, false).catch((error) => { + // logger.error("Error sending notification (concurrency limit reached): ", error); + // }); } await Promise.all(