Properly pass RetrySettings parameter in the functional rpc API.

restatedev · Jan 29, 2024 · a747319 · a747319
1 parent 63017c8
commit a747319
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/restate_context_impl.ts b/src/restate_context_impl.ts
@@ -596,8 +596,11 @@ export class RpcContextImpl implements RpcContext {
   public clear(name: string): void {
     this.ctx.clear(name);
   }
-  public sideEffect<T>(fn: () => Promise<T>): Promise<T> {
-    return this.ctx.sideEffect(fn);
+  public sideEffect<T>(
+    fn: () => Promise<T>,
+    retryPolicy?: RetrySettings
+  ): Promise<T> {
+    return this.ctx.sideEffect(fn, retryPolicy);
   }
   public awakeable<T>(): { id: string; promise: Promise<T> } {
     return this.ctx.awakeable();