From 633d9715871eda1915cdc1e3953ad630722415be Mon Sep 17 00:00:00 2001 From: Matt Aitken Date: Tue, 17 Jun 2025 17:58:24 +0100 Subject: [PATCH 1/2] =?UTF-8?q?Fix=20for=20v3=20rescheduling=20bug?= =?UTF-8?q?=E2=80=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/webapp/app/v3/services/rescheduleTaskRun.server.ts | 1 + 1 file changed, 1 insertion(+) diff --git a/apps/webapp/app/v3/services/rescheduleTaskRun.server.ts b/apps/webapp/app/v3/services/rescheduleTaskRun.server.ts index 122fcc2c59..8b846af19c 100644 --- a/apps/webapp/app/v3/services/rescheduleTaskRun.server.ts +++ b/apps/webapp/app/v3/services/rescheduleTaskRun.server.ts @@ -22,6 +22,7 @@ export class RescheduleTaskRunService extends BaseService { }, data: { delayUntil: delay, + queueTimestamp: delay, }, }); From a583d3ca591add95e03c8a2dab59e38b4325218a Mon Sep 17 00:00:00 2001 From: Matt Aitken Date: Tue, 17 Jun 2025 18:06:41 +0100 Subject: [PATCH 2/2] v4 rescheduling working --- .../webapp/app/v3/services/rescheduleTaskRun.server.ts | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/apps/webapp/app/v3/services/rescheduleTaskRun.server.ts b/apps/webapp/app/v3/services/rescheduleTaskRun.server.ts index 8b846af19c..43163fb4fb 100644 --- a/apps/webapp/app/v3/services/rescheduleTaskRun.server.ts +++ b/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 }); + } } }