v4 rescheduling working

Author: matt-aitken

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

@@ -3,6 +3,7 @@ import { TaskRun } from "@trigger.dev/database";
 import { parseDelay } from "~/utils/delays";
 import { BaseService, ServiceValidationError } from "./baseService.server";
 import { EnqueueDelayedRunService } from "./enqueueDelayedRun.server";
+import { engine } from "../runEngine.server";
 
 export class RescheduleTaskRunService extends BaseService {
   public async call(taskRun: TaskRun, body: RescheduleRunRequestBody) {
@@ -26,8 +27,11 @@ export class RescheduleTaskRunService extends BaseService {
       },
     });
 
-    await EnqueueDelayedRunService.reschedule(taskRun.id, delay);
-
-    return updatedRun;
+    if (updatedRun.engine === "V1") {
+      await EnqueueDelayedRunService.reschedule(taskRun.id, delay);
+      return updatedRun;
+    } else {
+      return engine.rescheduleDelayedRun({ runId: taskRun.id, delayUntil: delay });
+    }
   }
 }