Pass through the parentRunId and resumeParentOnCompletion

Author: matt-aitken

apps/webapp/app/services/worker.server.ts

@@ -56,6 +56,10 @@ import {
 } from "~/v3/services/cancelDevSessionRuns.server";
 import { logger } from "./logger.server";
 import { BatchProcessingOptions, BatchTriggerV2Service } from "~/v3/services/batchTriggerV2.server";
+import {
+  BatchProcessingOptions as BatchProcessingOptionsV3,
+  BatchTriggerV3Service,
+} from "~/v3/services/batchTriggerV3.server";
 
 const workerCatalog = {
   indexEndpoint: z.object({
@@ -199,6 +203,7 @@ const workerCatalog = {
   }),
   "v3.cancelDevSessionRuns": CancelDevSessionRunsServiceOptions,
   "v3.processBatchTaskRun": BatchProcessingOptions,
+  "v3.processBatchTaskRunV3": BatchProcessingOptionsV3,
 };
 
 const executionWorkerCatalog = {
@@ -735,6 +740,15 @@ function getWorkerQueue() {
         handler: async (payload, job) => {
           const service = new BatchTriggerV2Service(payload.strategy);
 
+          await service.processBatchTaskRun(payload);
+        },
+      },
+      "v3.processBatchTaskRunV3": {
+        priority: 0,
+        maxAttempts: 5,
+        handler: async (payload, job) => {
+          const service = new BatchTriggerV3Service(payload.strategy);
+
           await service.processBatchTaskRun(payload);
         },
       },

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

@@ -759,6 +759,8 @@ export class BatchTriggerV3Service extends WithRunEngine {
           task: item,
           currentIndex: workingIndex,
           options,
+          parentRunId,
+          resumeParentOnCompletion,
         });
 
         workingIndex++;
@@ -799,8 +801,8 @@ export class BatchTriggerV3Service extends WithRunEngine {
     task: { runFriendlyId: string; item: BatchTriggerTaskV2RequestBody["items"][number] };
     currentIndex: number;
     options?: BatchTriggerTaskServiceOptions;
-    parentRunId?: string | undefined;
-    resumeParentOnCompletion?: boolean | undefined;
+    parentRunId: string | undefined;
+    resumeParentOnCompletion: boolean | undefined;
   }) {
     logger.debug("[BatchTriggerV3][processBatchTaskRunItem] Processing item", {
       batchId: batch.friendlyId,