Skip to content

Commit dde3c00

Browse files
committed
Don't use the organization max concurrency anymore
1 parent 6137338 commit dde3c00

File tree

2 files changed

+2
-10
lines changed

2 files changed

+2
-10
lines changed

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

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -361,14 +361,7 @@ async function createWorkerQueue(
361361

362362
const baseConcurrencyLimit =
363363
typeof queue.concurrencyLimit === "number"
364-
? Math.max(
365-
Math.min(
366-
queue.concurrencyLimit,
367-
environment.maximumConcurrencyLimit,
368-
environment.organization.maximumConcurrencyLimit
369-
),
370-
0
371-
)
364+
? Math.max(Math.min(queue.concurrencyLimit, environment.maximumConcurrencyLimit), 0)
372365
: queue.concurrencyLimit;
373366

374367
const taskQueue = await upsertWorkerQueueRecord(

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -476,8 +476,7 @@ export class TriggerTaskServiceV1 extends BaseService {
476476
? Math.max(
477477
Math.min(
478478
body.options.queue.concurrencyLimit,
479-
environment.maximumConcurrencyLimit,
480-
environment.organization.maximumConcurrencyLimit
479+
environment.maximumConcurrencyLimit
481480
),
482481
0
483482
)

0 commit comments

Comments
 (0)