From 767dc5f6528e9bf51468b240f9f6b2d82175fabb Mon Sep 17 00:00:00 2001 From: Matt Aitken Date: Sun, 9 Feb 2025 21:19:39 +0000 Subject: [PATCH] =?UTF-8?q?If=20there=E2=80=99s=20no=20queue=20concurrency?= =?UTF-8?q?=20limit,=20default=20to=20the=20env=20concurrency=20limit=20(n?= =?UTF-8?q?ot=201m)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/webapp/app/v3/marqs/index.server.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/webapp/app/v3/marqs/index.server.ts b/apps/webapp/app/v3/marqs/index.server.ts index 9ec891b7e3..dfe5a6028d 100644 --- a/apps/webapp/app/v3/marqs/index.server.ts +++ b/apps/webapp/app/v3/marqs/index.server.ts @@ -1264,7 +1264,7 @@ end -- Check current queue concurrency against the limit local currentConcurrency = tonumber(redis.call('SCARD', currentConcurrencyKey) or '0') -local concurrencyLimit = tonumber(redis.call('GET', concurrencyLimitKey) or '1000000') +local concurrencyLimit = tonumber(redis.call('GET', concurrencyLimitKey) or envConcurrencyLimit) -- Check condition only if concurrencyLimit exists if currentConcurrency >= concurrencyLimit then @@ -1434,7 +1434,7 @@ local currentEnvConcurrency = tonumber(redis.call('SCARD', currentEnvConcurrency local currentConcurrency = tonumber(redis.call('SCARD', currentConcurrencyKey) or '0') -return { currentOrgConcurrency, currentEnvConcurrency, currentConcurrency } +return { currentOrgConcurrency, currentEnvConcurrency, currentConcurrency } `, });