Skip to content

Commit 8eaf18b

Browse files
committed
fix function runner servicer type
Signed-off-by: Eric Carlsson <97894605+eric-carlsson@users.noreply.github.com>
1 parent ad6f1e1 commit 8eaf18b

1 file changed

Lines changed: 5 additions & 5 deletions

File tree

crossplane/function/runtime.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ def load_credentials(tls_certs_dir: str) -> grpc.ServerCredentials:
7070

7171

7272
def 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

Comments
 (0)