Task queues weren’t setting concurrencyLimit or releaseConcurrencyOnWaitpoint (#1844)

matt-aitken · web-flow · commit 5640467ce586 · 2025-03-28T15:53:56.000Z
diff --git a/apps/webapp/app/v3/services/createBackgroundWorker.server.ts b/apps/webapp/app/v3/services/createBackgroundWorker.server.ts
@@ -246,6 +246,8 @@ async function createWorkerTask(
       queue = await createWorkerQueue(
         {
           name: `task/${task.id}`,
+          concurrencyLimit: task.queue?.concurrencyLimit,
+          releaseConcurrencyOnWaitpoint: task.queue?.releaseConcurrencyOnWaitpoint,
         },
         task.id,
         "VIRTUAL",

Original file line number	Diff line number	Diff line change
`@@ -246,6 +246,8 @@ async function createWorkerTask(`
`246`	`246`	`queue = await createWorkerQueue(`
`247`	`247`	`{`
`248`	`248`	name: `task/${task.id}`,
	`249`	`+ concurrencyLimit: task.queue?.concurrencyLimit,`
	`250`	`+ releaseConcurrencyOnWaitpoint: task.queue?.releaseConcurrencyOnWaitpoint,`
`249`	`251`	`},`
`250`	`252`	`task.id,`
`251`	`253`	`"VIRTUAL",`