@@ -70,7 +70,7 @@ def load_credentials(tls_certs_dir: str) -> grpc.ServerCredentials:
7070
7171
7272def serve (
73- function : grpcv1 .FunctionRunnerService ,
73+ function : grpcv1 .FunctionRunnerServiceServicer ,
7474 address : str ,
7575 * ,
7676 creds : grpc .ServerCredentials ,
@@ -134,20 +134,20 @@ async def start():
134134 loop .close ()
135135
136136
137- class BetaFunctionRunner (grpcv1beta1 .FunctionRunnerService ):
137+ class BetaFunctionRunner (grpcv1beta1 .FunctionRunnerServiceServicer ):
138138 """A BetaFunctionRunner handles beta gRPC RunFunctionRequests.
139139
140- It handles requests by passing them to a wrapped v1.FunctionRunnerService .
140+ It handles requests by passing them to a wrapped v1.FunctionRunnerServiceServicer .
141141 Incoming v1beta1 requests are converted to v1 by round-tripping them through
142142 serialization. Outgoing requests are converted from v1 to v1beta1 the same
143143 way.
144144 """
145145
146- def __init__ (self , wrapped : grpcv1 .FunctionRunnerService ):
146+ def __init__ (self , wrapped : grpcv1 .FunctionRunnerServiceServicer ):
147147 """Create a new BetaFunctionRunner."""
148148 self .wrapped = wrapped
149149
150- async def RunFunction ( # noqa: N802 # gRPC requires this name.
150+ async def RunFunction ( # noqa: N802 # gRPC requires this name. # pyright: ignore[reportIncompatibleMethodOverride]
151151 self , req : fnv1beta1 .RunFunctionRequest , context : grpc .aio .ServicerContext
152152 ) -> fnv1beta1 .RunFunctionResponse :
153153 """Run the underlying function."""
0 commit comments