From 8a6024f4619fb221bf9234d2dae5e3fe61474fa8 Mon Sep 17 00:00:00 2001 From: Eric Allam Date: Fri, 28 Mar 2025 17:54:45 +0000 Subject: [PATCH] fix: custom queues defined on tasks on v3 now get correctly created --- apps/webapp/app/v3/services/createBackgroundWorker.server.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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