Skip to content

Commit bc7d445

Browse files
authored
If there’s no queue concurrency limit, default to the env concurrency limit (not 1m) (#1687)
1 parent 2771fd7 commit bc7d445

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

apps/webapp/app/v3/marqs/index.server.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1264,7 +1264,7 @@ end
12641264
12651265
-- Check current queue concurrency against the limit
12661266
local currentConcurrency = tonumber(redis.call('SCARD', currentConcurrencyKey) or '0')
1267-
local concurrencyLimit = tonumber(redis.call('GET', concurrencyLimitKey) or '1000000')
1267+
local concurrencyLimit = tonumber(redis.call('GET', concurrencyLimitKey) or envConcurrencyLimit)
12681268
12691269
-- Check condition only if concurrencyLimit exists
12701270
if currentConcurrency >= concurrencyLimit then
@@ -1434,7 +1434,7 @@ local currentEnvConcurrency = tonumber(redis.call('SCARD', currentEnvConcurrency
14341434
14351435
local currentConcurrency = tonumber(redis.call('SCARD', currentConcurrencyKey) or '0')
14361436
1437-
return { currentOrgConcurrency, currentEnvConcurrency, currentConcurrency }
1437+
return { currentOrgConcurrency, currentEnvConcurrency, currentConcurrency }
14381438
`,
14391439
});
14401440

0 commit comments

Comments
 (0)