diff --git a/services/node-services/src/embedded_handler_api.ts b/services/node-services/src/embedded_handler_api.ts index 67263bb3..cd3709ba 100644 --- a/services/node-services/src/embedded_handler_api.ts +++ b/services/node-services/src/embedded_handler_api.ts @@ -101,20 +101,16 @@ app.post("/consecutive_side_effects", async (req: Request, res: Response) => { const result = await rs.invoke(id, {}, async (ctx: restate.RpcContext) => { let invocationCount = 0; - const p1 = ctx.sideEffect(async () => { + await ctx.sideEffect(async () => { invocationCount++; }); - const p2 = ctx.sideEffect(async () => { + await ctx.sideEffect(async () => { invocationCount++; }); - const p3 = ctx.sideEffect(async () => { + await ctx.sideEffect(async () => { invocationCount++; }); - await p1; - await p2; - await p3; - return { invocationCount }; });