Make sure releaseConcurrencyOnWaitpoint is set on taskQueue

Author: matt-aitken

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

@@ -368,6 +368,7 @@ async function createWorkerQueue(
     concurrencyLimit ?? undefined,
     orderableName,
     queueType,
+    queue.releaseConcurrencyOnWaitpoint,
     worker,
     prisma
   );
@@ -402,6 +403,7 @@ async function upsertWorkerQueueRecord(
   concurrencyLimit: number | undefined,
   orderableName: string,
   queueType: TaskQueueType,
+  releaseConcurrencyOnWaitpoint: boolean | undefined,
   worker: BackgroundWorker,
   prisma: PrismaClientOrTransaction,
   attempt: number = 0
@@ -429,6 +431,7 @@ async function upsertWorkerQueueRecord(
           runtimeEnvironmentId: worker.runtimeEnvironmentId,
           projectId: worker.projectId,
           type: queueType,
+          releaseConcurrencyOnWaitpoint,
           workers: {
             connect: {
               id: worker.id,
@@ -437,14 +440,15 @@ async function upsertWorkerQueueRecord(
         },
       });
     } else {
-      await prisma.taskQueue.update({
+      taskQueue = await prisma.taskQueue.update({
         where: {
           id: taskQueue.id,
         },
         data: {
           workers: { connect: { id: worker.id } },
           version: "V2",
           orderableName,
+          releaseConcurrencyOnWaitpoint,
         },
       });
     }
@@ -458,6 +462,7 @@ async function upsertWorkerQueueRecord(
         concurrencyLimit,
         orderableName,
         queueType,
+        releaseConcurrencyOnWaitpoint,
         worker,
         prisma,
         attempt + 1