Compare commits

...

1 Commits

Author SHA1 Message Date
Matt Aitken 170dabf69f Delay reschedule fix (v3 & v4) (#2180)
🚀 Publish Trigger.dev Docker / units (push) Failing after 0s
🚀 Publish Trigger.dev Docker / typecheck (push) Failing after 7s
🚀 Publish Trigger.dev Docker / publish-webapp (push) Has been skipped
🚀 Publish Trigger.dev Docker / publish-worker (push) Has been skipped
🚀 Publish Trigger.dev Docker / publish-worker-v4 (push) Has been skipped
* Fix for v3 rescheduling bug…

* v4 rescheduling working
2025-06-24 11:27:53 +01:00
@@ -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) {
@@ -22,11 +23,15 @@ export class RescheduleTaskRunService extends BaseService {
},
data: {
delayUntil: delay,
queueTimestamp: delay,
},
});
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 });
}
}
}