Update queue-jobs.ts

mendableai · Jan 30, 2025 · b44358a · b44358a
1 parent 425378b
commit b44358a
Showing 1 changed file with 6 additions and 6 deletions.
diff --git 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(