From e9086b49f60f69f3733cca375fca6f47c6aca0ff Mon Sep 17 00:00:00 2001
From: Thomas Trompette <thomas.trompette@sfr.fr>
Date: Tue, 9 Jun 2026 14:47:53 +0200
Subject: [PATCH] Increase logicFunctionQueue worker concurrency to 10 (#21364)
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

## Summary
- Increase BullMQ worker concurrency for `logicFunctionQueue` from 1
(default) to 10
- Logic function executions are I/O-bound Lambda calls — the worker just
holds an HTTP connection open, so higher concurrency doesn't add
CPU/memory pressure
- With 13 worker pods, this goes from 13 to ~130 concurrent slots, which
should resolve the ~3h average queue latency observed in Grafana

## Test plan
- [ ] Monitor `avg_latency_ms` for `logic-function-queue` in the Grafana
job queue dashboard after deploy
- [ ] Verify worker pod CPU/memory remains stable
---
 .../message-queue/message-queue-worker-options.constant.ts       | 1 +
 1 file changed, 1 insertion(+)

diff --git a/packages/twenty-server/src/engine/core-modules/message-queue/message-queue-worker-options.constant.ts b/packages/twenty-server/src/engine/core-modules/message-queue/message-queue-worker-options.constant.ts
index 3ad3aee11c5..004bb703ab3 100644
--- a/packages/twenty-server/src/engine/core-modules/message-queue/message-queue-worker-options.constant.ts
+++ b/packages/twenty-server/src/engine/core-modules/message-queue/message-queue-worker-options.constant.ts
@@ -4,4 +4,5 @@ export const QUEUE_WORKER_OPTIONS: Partial<
   Record<MessageQueue, { concurrency: number }>
 > = {
   [MessageQueue.aiStreamQueue]: { concurrency: 20 },
+  [MessageQueue.logicFunctionQueue]: { concurrency: 10 },
 };