diff --git a/apps/webapp/app/v3/services/createBackgroundWorker.server.ts b/apps/webapp/app/v3/services/createBackgroundWorker.server.ts index 5a4a5b1a0b..5ee2a7dbee 100644 --- a/apps/webapp/app/v3/services/createBackgroundWorker.server.ts +++ b/apps/webapp/app/v3/services/createBackgroundWorker.server.ts @@ -245,12 +245,12 @@ async function createWorkerTask( // Create a TaskQueue queue = await createWorkerQueue( { - name: `task/${task.id}`, + name: task.queue?.name ?? `task/${task.id}`, concurrencyLimit: task.queue?.concurrencyLimit, releaseConcurrencyOnWaitpoint: task.queue?.releaseConcurrencyOnWaitpoint, }, task.id, - "VIRTUAL", + task.queue?.name ? "NAMED" : "VIRTUAL", worker, environment, prisma