Skip to content

Commit a747319

Browse files
committed
Properly pass RetrySettings parameter in the functional rpc API.
1 parent 63017c8 commit a747319

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/restate_context_impl.ts

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -596,8 +596,11 @@ export class RpcContextImpl implements RpcContext {
596596
public clear(name: string): void {
597597
this.ctx.clear(name);
598598
}
599-
public sideEffect<T>(fn: () => Promise<T>): Promise<T> {
600-
return this.ctx.sideEffect(fn);
599+
public sideEffect<T>(
600+
fn: () => Promise<T>,
601+
retryPolicy?: RetrySettings
602+
): Promise<T> {
603+
return this.ctx.sideEffect(fn, retryPolicy);
601604
}
602605
public awakeable<T>(): { id: string; promise: Promise<T> } {
603606
return this.ctx.awakeable();

0 commit comments

Comments
 (0)