test with 1 message processing at a time

CrowdDotDev · Jan 12, 2025 · 707be16 · 707be16
1 parent 5dbe45d
commit 707be16
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/services/apps/data_sink_worker/src/queue/index.ts b/services/apps/data_sink_worker/src/queue/index.ts
@@ -30,7 +30,7 @@ export class WorkerQueueReceiver extends PrioritizedQueueReciever {
       level,
       client,
       client.getQueueChannelConfig(CrowdQueue.DATA_SINK_WORKER),
-      3,
+      1,
       parentLog,
       undefined,
       undefined,