We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8122a0b commit 51f2578Copy full SHA for 51f2578
packages/restate-sdk/src/promises.ts
@@ -442,6 +442,10 @@ export class PromisesExecutor {
442
restatePromise.tryCancel();
443
return;
444
} else {
445
+ // If we're in this branch, there might be a ctx.run command waiting to be flushed
446
+ // Let's flush it to notify early the runtime we're gonna run a ctx.run
447
+ await this.outputPump.awaitNextProgress();
448
+
449
// We need to execute a run closure
450
this.runClosuresTracker.executeRun(doProgressResult.ExecuteRun);
451
// Let the run context switch, then come back to this flow.
0 commit comments