From 113f52747a5abc87ae1b1a808bc7c9016518693d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Uro=C5=A1=20Marolt?= Date: Sun, 12 Jan 2025 10:48:17 +0100 Subject: [PATCH] test with 2 message processing at a time --- services/apps/data_sink_worker/src/queue/index.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/services/apps/data_sink_worker/src/queue/index.ts b/services/apps/data_sink_worker/src/queue/index.ts index 94d143ff6..cea052dcb 100644 --- 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,