add fixme comments
This commit is contained in:
@@ -57,6 +57,8 @@ export class SharedRuntimeManager implements RuntimeManager {
|
||||
runId: params.id,
|
||||
});
|
||||
|
||||
// FIXME: We need to send a "ready to checkpoint" signal here
|
||||
|
||||
const waitpoint = await promise;
|
||||
const result = this.waitpointToTaskRunExecutionResult(waitpoint);
|
||||
|
||||
@@ -96,6 +98,8 @@ export class SharedRuntimeManager implements RuntimeManager {
|
||||
runCount: params.runCount,
|
||||
});
|
||||
|
||||
// FIXME: We need to send a "ready to checkpoint" signal here
|
||||
|
||||
const waitpoints = await Promise.all(promises);
|
||||
|
||||
await lifecycleHooks.callOnResumeHookListeners({
|
||||
@@ -138,6 +142,8 @@ export class SharedRuntimeManager implements RuntimeManager {
|
||||
});
|
||||
}
|
||||
|
||||
// FIXME: We need to send a "ready to checkpoint" signal here
|
||||
|
||||
const waitpoint = await promise;
|
||||
|
||||
if (finishDate) {
|
||||
|
||||
Reference in New Issue
Block a user