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.`);