@@ -85,16 +85,20 @@ export class ResumeTaskDependencyService extends BaseService {
8585        return ; 
8686      } 
8787
88-       await  marqs ?. replaceMessage ( dependentRun . id ,  { 
89-         type : "RESUME" , 
90-         completedAttemptIds : [ sourceTaskAttemptId ] , 
91-         resumableAttemptId : dependency . dependentAttempt . id , 
92-         checkpointEventId : dependency . checkpointEventId  ??  undefined , 
93-         taskIdentifier : dependency . taskRun . taskIdentifier , 
94-         projectId : dependency . taskRun . runtimeEnvironment . projectId , 
95-         environmentId : dependency . taskRun . runtimeEnvironment . id , 
96-         environmentType : dependency . taskRun . runtimeEnvironment . type , 
97-       } ) ; 
88+       await  marqs ?. replaceMessage ( 
89+         dependentRun . id , 
90+         { 
91+           type : "RESUME" , 
92+           completedAttemptIds : [ sourceTaskAttemptId ] , 
93+           resumableAttemptId : dependency . dependentAttempt . id , 
94+           checkpointEventId : dependency . checkpointEventId  ??  undefined , 
95+           taskIdentifier : dependency . taskRun . taskIdentifier , 
96+           projectId : dependency . taskRun . runtimeEnvironment . projectId , 
97+           environmentId : dependency . taskRun . runtimeEnvironment . id , 
98+           environmentType : dependency . taskRun . runtimeEnvironment . type , 
99+         } , 
100+         dependentRun . createdAt . getTime ( ) 
101+       ) ; 
98102    } 
99103  } 
100104
0 commit comments