@@ -85,16 +85,20 @@ export class ResumeTaskDependencyService extends BaseService {
85
85
return ;
86
86
}
87
87
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
+ ) ;
98
102
}
99
103
}
100
104
0 commit comments