diff --git a/packages/core/src/v3/runtime/sharedRuntimeManager.ts b/packages/core/src/v3/runtime/sharedRuntimeManager.ts index 9882e893b..2f38ec7f8 100644 --- a/packages/core/src/v3/runtime/sharedRuntimeManager.ts +++ b/packages/core/src/v3/runtime/sharedRuntimeManager.ts @@ -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) {