From 2286c331d30fa068304183fec8f2afae3619476a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= Date: Wed, 12 Nov 2025 11:08:12 +0100 Subject: [PATCH] fix --- packages/queue/src/queues.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/queue/src/queues.ts b/packages/queue/src/queues.ts index 0395cc14..e1e64645 100644 --- a/packages/queue/src/queues.ts +++ b/packages/queue/src/queues.ts @@ -144,11 +144,11 @@ const autoBatchSize = Number.parseInt(process.env.AUTO_BATCH_SIZE || '0', 10); export const eventsGroupQueues = Array.from({ length: EVENTS_GROUP_QUEUES_SHARDS, }).map( - (_, index) => + (_, index, list) => new GroupQueue({ logger: queueLogger, namespace: getQueueName( - index === 0 ? 'group_events' : `group_events_${index}`, + list.length === 1 ? 'group_events' : `group_events_${index}`, ), redis: getRedisGroupQueue(), keepCompleted: 1_000,