From 3ee72af0dbe9c53965275bed24b138339c916a6d Mon Sep 17 00:00:00 2001
From: Ayush <bhandariayush935@gmail.com>
Date: Tue, 30 Jun 2026 13:51:12 +0530
Subject: [PATCH] Added rate limiter to the bullMQ worker

---
 apps/consumer/src/workers/export.worker.js | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/apps/consumer/src/workers/export.worker.js b/apps/consumer/src/workers/export.worker.js
index 727e87e79..3390af5d3 100644
--- a/apps/consumer/src/workers/export.worker.js
+++ b/apps/consumer/src/workers/export.worker.js
@@ -224,7 +224,14 @@ const initExportWorker = () => {
             maxExportRows: MAX_EXPORT_ROWS
         });
         console.log(`[ExportWorker] Export completed! Email queued for ${email}${wasTruncated ? ' (truncated)' : ''}`);
-    }, { connection: redis, concurrency: 2 });
+    }, { 
+        connection: redis, 
+        concurrency: 2,
+        limiter: {
+            max: 10,
+            duration: 60000
+        }
+    });
 
     worker.on('completed', (job) => {
         console.log(`[ExportWorker] Job ${job.id} for project ${job.data.projectId} completed.`);