|
|
|
"""Client and server classes corresponding to protobuf-defined services.""" |
|
import grpc |
|
import warnings |
|
|
|
import inference_pb2 as inference__pb2 |
|
|
|
GRPC_GENERATED_VERSION = '1.65.1' |
|
GRPC_VERSION = grpc.__version__ |
|
EXPECTED_ERROR_RELEASE = '1.66.0' |
|
SCHEDULED_RELEASE_DATE = 'August 6, 2024' |
|
_version_not_supported = False |
|
|
|
try: |
|
from grpc._utilities import first_version_is_lower |
|
_version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) |
|
except ImportError: |
|
_version_not_supported = True |
|
|
|
if _version_not_supported: |
|
warnings.warn( |
|
f'The grpc package installed is at version {GRPC_VERSION},' |
|
+ f' but the generated code in inference_pb2_grpc.py depends on' |
|
+ f' grpcio>={GRPC_GENERATED_VERSION}.' |
|
+ f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' |
|
+ f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' |
|
+ f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' |
|
+ f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', |
|
RuntimeWarning |
|
) |
|
|
|
|
|
class GuideAndRescaleServiceStub(object): |
|
"""Missing associated documentation comment in .proto file.""" |
|
|
|
def __init__(self, channel): |
|
"""Constructor. |
|
|
|
Args: |
|
channel: A grpc.Channel. |
|
""" |
|
self.swap = channel.unary_unary( |
|
'/inference.GuideAndRescaleService/swap', |
|
request_serializer=inference__pb2.GuideAndRescaleRequest.SerializeToString, |
|
response_deserializer=inference__pb2.GuideAndRescaleResponse.FromString, |
|
_registered_method=True) |
|
|
|
|
|
class GuideAndRescaleServiceServicer(object): |
|
"""Missing associated documentation comment in .proto file.""" |
|
|
|
def swap(self, request, context): |
|
"""Missing associated documentation comment in .proto file.""" |
|
context.set_code(grpc.StatusCode.UNIMPLEMENTED) |
|
context.set_details('Method not implemented!') |
|
raise NotImplementedError('Method not implemented!') |
|
|
|
|
|
def add_GuideAndRescaleServiceServicer_to_server(servicer, server): |
|
rpc_method_handlers = { |
|
'swap': grpc.unary_unary_rpc_method_handler( |
|
servicer.swap, |
|
request_deserializer=inference__pb2.GuideAndRescaleRequest.FromString, |
|
response_serializer=inference__pb2.GuideAndRescaleResponse.SerializeToString, |
|
), |
|
} |
|
generic_handler = grpc.method_handlers_generic_handler( |
|
'inference.GuideAndRescaleService', rpc_method_handlers) |
|
server.add_generic_rpc_handlers((generic_handler,)) |
|
server.add_registered_method_handlers('inference.GuideAndRescaleService', rpc_method_handlers) |
|
|
|
|
|
|
|
class GuideAndRescaleService(object): |
|
"""Missing associated documentation comment in .proto file.""" |
|
|
|
@staticmethod |
|
def swap(request, |
|
target, |
|
options=(), |
|
channel_credentials=None, |
|
call_credentials=None, |
|
insecure=False, |
|
compression=None, |
|
wait_for_ready=None, |
|
timeout=None, |
|
metadata=None): |
|
return grpc.experimental.unary_unary( |
|
request, |
|
target, |
|
'/inference.GuideAndRescaleService/swap', |
|
inference__pb2.GuideAndRescaleRequest.SerializeToString, |
|
inference__pb2.GuideAndRescaleResponse.FromString, |
|
options, |
|
channel_credentials, |
|
insecure, |
|
call_credentials, |
|
compression, |
|
wait_for_ready, |
|
timeout, |
|
metadata, |
|
_registered_method=True) |
|
|