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";
33import  {  parseDelay  }  from  "~/utils/delays" ; 
44import  {  BaseService ,  ServiceValidationError  }  from  "./baseService.server" ; 
55import  {  EnqueueDelayedRunService  }  from  "./enqueueDelayedRun.server" ; 
6+ import  {  engine  }  from  "../runEngine.server" ; 
67
78export  class  RescheduleTaskRunService  extends  BaseService  { 
89  public  async  call ( taskRun : TaskRun ,  body : RescheduleRunRequestBody )  { 
@@ -22,11 +23,15 @@ export class RescheduleTaskRunService extends BaseService {
2223      } , 
2324      data : { 
2425        delayUntil : delay , 
26+         queueTimestamp : delay , 
2527      } , 
2628    } ) ; 
2729
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+     } 
3136  } 
3237} 
    
 
   
 
     
   
   
          
     
  
    
     
 
    
      
     
 
     
    You can’t perform that action at this time.
  
 
    
  
     
    
      
        
     
 
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments