Skip to content

Commit ec6e78e

Browse files
authored
Added rate limiter to the bullMQ worker (#346)
1 parent ce7d4eb commit ec6e78e

1 file changed

Lines changed: 8 additions & 1 deletion

File tree

apps/consumer/src/workers/export.worker.js

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -224,7 +224,14 @@ const initExportWorker = () => {
224224
maxExportRows: MAX_EXPORT_ROWS
225225
});
226226
console.log(`[ExportWorker] Export completed! Email queued for ${email}${wasTruncated ? ' (truncated)' : ''}`);
227-
}, { connection: redis, concurrency: 2 });
227+
}, {
228+
connection: redis,
229+
concurrency: 2,
230+
limiter: {
231+
max: 10,
232+
duration: 60000
233+
}
234+
});
228235

229236
worker.on('completed', (job) => {
230237
console.log(`[ExportWorker] Job ${job.id} for project ${job.data.projectId} completed.`);

0 commit comments

Comments
 (0)