test with 2 message processing at a time

CrowdDotDev · Jan 12, 2025 · 113f527 · 113f527
1 parent 707be16
commit 113f527
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),
-      1,
+      2,
       parentLog,
       undefined,
       undefined,