File tree Expand file tree Collapse file tree 1 file changed +8
-3
lines changed
apps/webapp/app/v3/services Expand file tree Collapse file tree 1 file changed +8
-3
lines changed Original file line number Diff line number Diff line change @@ -3,6 +3,7 @@ import { TaskRun } from "@trigger.dev/database";
3
3
import { parseDelay } from "~/utils/delays" ;
4
4
import { BaseService , ServiceValidationError } from "./baseService.server" ;
5
5
import { EnqueueDelayedRunService } from "./enqueueDelayedRun.server" ;
6
+ import { engine } from "../runEngine.server" ;
6
7
7
8
export class RescheduleTaskRunService extends BaseService {
8
9
public async call ( taskRun : TaskRun , body : RescheduleRunRequestBody ) {
@@ -22,11 +23,15 @@ export class RescheduleTaskRunService extends BaseService {
22
23
} ,
23
24
data : {
24
25
delayUntil : delay ,
26
+ queueTimestamp : delay ,
25
27
} ,
26
28
} ) ;
27
29
28
- await EnqueueDelayedRunService . reschedule ( taskRun . id , delay ) ;
29
-
30
- return updatedRun ;
30
+ if ( updatedRun . engine === "V1" ) {
31
+ await EnqueueDelayedRunService . reschedule ( taskRun . id , delay ) ;
32
+ return updatedRun ;
33
+ } else {
34
+ return engine . rescheduleDelayedRun ( { runId : taskRun . id , delayUntil : delay } ) ;
35
+ }
31
36
}
32
37
}
You can’t perform that action at this time.
0 commit comments