File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
packages/core/src/v3/runtime Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change
1
+ import { clock } from "../clock-api.js" ;
1
2
import { lifecycleHooks } from "../lifecycle-hooks-api.js" ;
2
3
import {
3
4
BatchTaskRunExecutionResult ,
4
5
CompletedWaitpoint ,
5
- RuntimeWait ,
6
6
TaskRunContext ,
7
7
TaskRunExecutionResult ,
8
8
TaskRunFailedExecutionResult ,
@@ -178,21 +178,22 @@ export class ManagedRuntimeManager implements RuntimeManager {
178
178
}
179
179
180
180
if ( ! waitId ) {
181
- // TODO: Handle failures better
182
181
this . log ( "No waitId found for waitpoint" , waitpoint ) ;
183
182
return ;
184
183
}
185
184
186
185
const resolve = this . resolversByWaitId . get ( waitId ) ;
187
186
188
187
if ( ! resolve ) {
189
- // TODO: Handle failures better
190
188
this . log ( "No resolver found for waitId" , waitId ) ;
191
189
return ;
192
190
}
193
191
194
192
this . log ( "Resolving waitpoint" , waitpoint ) ;
195
193
194
+ // Ensure current time is accurate before resolving the waitpoint
195
+ clock . reset ( ) ;
196
+
196
197
resolve ( waitpoint ) ;
197
198
198
199
this . resolversByWaitId . delete ( waitId ) ;
You can’t perform that action at this time.
0 commit comments