Skip to content

Commit a4765b0

Browse files
authored
examples: add idempotency_level (#96)
1 parent 913c21b commit a4765b0

File tree

1 file changed

+14
-6
lines changed

1 file changed

+14
-6
lines changed

examples/proto/connectrpc/eliza/v1/v1connect/eliza_connect_pb2.py

Lines changed: 14 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -7,12 +7,20 @@
77
import abc
88
from enum import Enum
99

10-
from connect.client import Client
11-
from connect.connect import StreamRequest, StreamResponse, UnaryRequest, UnaryResponse
10+
from connect import (
11+
Client,
12+
ClientOptions,
13+
ConnectOptions,
14+
Handler,
15+
HandlerContext,
16+
IdempotencyLevel,
17+
StreamRequest,
18+
StreamResponse,
19+
UnaryRequest,
20+
UnaryResponse,
21+
)
1222
from connect.connection_pool import AsyncConnectionPool
13-
from connect.handler import ClientStreamHandler, Handler, ServerStreamHandler, UnaryHandler, BidiStreamHandler
14-
from connect.handler_context import HandlerContext
15-
from connect.options import ClientOptions, ConnectOptions
23+
from connect.handler import BidiStreamHandler, ClientStreamHandler, ServerStreamHandler, UnaryHandler
1624
from google.protobuf.descriptor import MethodDescriptor, ServiceDescriptor
1725

1826
from .. import eliza_pb2
@@ -92,7 +100,7 @@ def create_ElizaService_handlers(service: ElizaServiceHandler, options: ConnectO
92100
unary=service.Say,
93101
input=SayRequest,
94102
output=SayResponse,
95-
options=options,
103+
options=ConnectOptions(idempotency_level=IdempotencyLevel.NO_SIDE_EFFECTS).merge(options),
96104
),
97105
BidiStreamHandler(
98106
procedure=ElizaServiceProcedures.Converse.value,

0 commit comments

Comments
 (0)