From 4d53f0735dba2e6c44cdf5e95d802d2a81716bf6 Mon Sep 17 00:00:00 2001 From: Eric Allam Date: Thu, 4 Dec 2025 13:23:07 +0000 Subject: [PATCH] fix(engine): prevent overriding a queue concurrency limit resuming a paused queue --- apps/webapp/app/v3/services/concurrencySystem.server.ts | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/apps/webapp/app/v3/services/concurrencySystem.server.ts b/apps/webapp/app/v3/services/concurrencySystem.server.ts index f151e98515..1a34fd61f2 100644 --- a/apps/webapp/app/v3/services/concurrencySystem.server.ts +++ b/apps/webapp/app/v3/services/concurrencySystem.server.ts @@ -173,6 +173,11 @@ function resetQueueConcurrencyLimit(db: PrismaClientOrTransaction, queue: TaskQu } function syncQueueConcurrencyToEngine(environment: AuthenticatedEnvironment, queue: TaskQueue) { + if (queue.paused) { + // Queue is paused, don't update Redis limits - keep at 0 + return okAsync(queue); + } + if (typeof queue.concurrencyLimit === "number") { return fromPromise( updateQueueConcurrencyLimits(environment, queue.name, queue.concurrencyLimit),