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 }
       `,
     });