Skip to content

Commit 8977d25

Browse files
authored
fix: custom queues defined on tasks on v3 now get correctly created (#1846)
1 parent af45e83 commit 8977d25

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -245,12 +245,12 @@ async function createWorkerTask(
245245
// Create a TaskQueue
246246
queue = await createWorkerQueue(
247247
{
248-
name: `task/${task.id}`,
248+
name: task.queue?.name ?? `task/${task.id}`,
249249
concurrencyLimit: task.queue?.concurrencyLimit,
250250
releaseConcurrencyOnWaitpoint: task.queue?.releaseConcurrencyOnWaitpoint,
251251
},
252252
task.id,
253-
"VIRTUAL",
253+
task.queue?.name ? "NAMED" : "VIRTUAL",
254254
worker,
255255
environment,
256256
prisma

0 commit comments

Comments
 (0)