Skip to content

Commit b01b874

Browse files
authored
fix(engine): prevent overriding a queue concurrency limit resuming a paused queue (#2745)
1 parent e7fec40 commit b01b874

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

apps/webapp/app/v3/services/concurrencySystem.server.ts

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -173,6 +173,11 @@ function resetQueueConcurrencyLimit(db: PrismaClientOrTransaction, queue: TaskQu
173173
}
174174

175175
function syncQueueConcurrencyToEngine(environment: AuthenticatedEnvironment, queue: TaskQueue) {
176+
if (queue.paused) {
177+
// Queue is paused, don't update Redis limits - keep at 0
178+
return okAsync(queue);
179+
}
180+
176181
if (typeof queue.concurrencyLimit === "number") {
177182
return fromPromise(
178183
updateQueueConcurrencyLimits(environment, queue.name, queue.concurrencyLimit),

0 commit comments

Comments
 (0)