From a423615969dac0d609d5d114b1c21189fec12900 Mon Sep 17 00:00:00 2001
From: Thomas Kaul <4159106+dtslvr@users.noreply.github.com>
Date: Wed, 24 Jun 2026 18:00:08 +0200
Subject: [PATCH] Improve throughput by applying rate limit per data source

---
 .../src/services/queues/data-gathering/data-gathering.module.ts  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/apps/api/src/services/queues/data-gathering/data-gathering.module.ts b/apps/api/src/services/queues/data-gathering/data-gathering.module.ts
index 5ac6c40c0..7258c034c 100644
--- a/apps/api/src/services/queues/data-gathering/data-gathering.module.ts
+++ b/apps/api/src/services/queues/data-gathering/data-gathering.module.ts
@@ -29,6 +29,7 @@ import { DataGatheringProcessor } from './data-gathering.processor';
     BullModule.registerQueue({
       limiter: {
         duration: ms('4 seconds'),
+        groupKey: 'dataSource',
         max: 1
       },
       name: DATA_GATHERING_QUEUE