From 4a52a71956a8d46fcb7294ac71734504bb09bcc2 Mon Sep 17 00:00:00 2001 From: S. Solomon Darnell Date: Fri, 28 Mar 2025 21:52:21 -0500 Subject: two version of R2R are here --- .../hatchet_sdk/contracts/events_pb2_grpc.py | 274 +++++++++++++++++++++ 1 file changed, 274 insertions(+) create mode 100644 .venv/lib/python3.12/site-packages/hatchet_sdk/contracts/events_pb2_grpc.py (limited to '.venv/lib/python3.12/site-packages/hatchet_sdk/contracts/events_pb2_grpc.py') diff --git a/.venv/lib/python3.12/site-packages/hatchet_sdk/contracts/events_pb2_grpc.py b/.venv/lib/python3.12/site-packages/hatchet_sdk/contracts/events_pb2_grpc.py new file mode 100644 index 00000000..ddea5aa4 --- /dev/null +++ b/.venv/lib/python3.12/site-packages/hatchet_sdk/contracts/events_pb2_grpc.py @@ -0,0 +1,274 @@ +# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! +"""Client and server classes corresponding to protobuf-defined services.""" +import grpc +import warnings + +from . import events_pb2 as events__pb2 + +GRPC_GENERATED_VERSION = '1.64.1' +GRPC_VERSION = grpc.__version__ +EXPECTED_ERROR_RELEASE = '1.65.0' +SCHEDULED_RELEASE_DATE = 'June 25, 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 events_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 EventsServiceStub(object): + """Missing associated documentation comment in .proto file.""" + + def __init__(self, channel): + """Constructor. + + Args: + channel: A grpc.Channel. + """ + self.Push = channel.unary_unary( + '/EventsService/Push', + request_serializer=events__pb2.PushEventRequest.SerializeToString, + response_deserializer=events__pb2.Event.FromString, + _registered_method=True) + self.BulkPush = channel.unary_unary( + '/EventsService/BulkPush', + request_serializer=events__pb2.BulkPushEventRequest.SerializeToString, + response_deserializer=events__pb2.Events.FromString, + _registered_method=True) + self.ReplaySingleEvent = channel.unary_unary( + '/EventsService/ReplaySingleEvent', + request_serializer=events__pb2.ReplayEventRequest.SerializeToString, + response_deserializer=events__pb2.Event.FromString, + _registered_method=True) + self.PutLog = channel.unary_unary( + '/EventsService/PutLog', + request_serializer=events__pb2.PutLogRequest.SerializeToString, + response_deserializer=events__pb2.PutLogResponse.FromString, + _registered_method=True) + self.PutStreamEvent = channel.unary_unary( + '/EventsService/PutStreamEvent', + request_serializer=events__pb2.PutStreamEventRequest.SerializeToString, + response_deserializer=events__pb2.PutStreamEventResponse.FromString, + _registered_method=True) + + +class EventsServiceServicer(object): + """Missing associated documentation comment in .proto file.""" + + def Push(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 BulkPush(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 ReplaySingleEvent(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 PutLog(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 PutStreamEvent(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_EventsServiceServicer_to_server(servicer, server): + rpc_method_handlers = { + 'Push': grpc.unary_unary_rpc_method_handler( + servicer.Push, + request_deserializer=events__pb2.PushEventRequest.FromString, + response_serializer=events__pb2.Event.SerializeToString, + ), + 'BulkPush': grpc.unary_unary_rpc_method_handler( + servicer.BulkPush, + request_deserializer=events__pb2.BulkPushEventRequest.FromString, + response_serializer=events__pb2.Events.SerializeToString, + ), + 'ReplaySingleEvent': grpc.unary_unary_rpc_method_handler( + servicer.ReplaySingleEvent, + request_deserializer=events__pb2.ReplayEventRequest.FromString, + response_serializer=events__pb2.Event.SerializeToString, + ), + 'PutLog': grpc.unary_unary_rpc_method_handler( + servicer.PutLog, + request_deserializer=events__pb2.PutLogRequest.FromString, + response_serializer=events__pb2.PutLogResponse.SerializeToString, + ), + 'PutStreamEvent': grpc.unary_unary_rpc_method_handler( + servicer.PutStreamEvent, + request_deserializer=events__pb2.PutStreamEventRequest.FromString, + response_serializer=events__pb2.PutStreamEventResponse.SerializeToString, + ), + } + generic_handler = grpc.method_handlers_generic_handler( + 'EventsService', rpc_method_handlers) + server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('EventsService', rpc_method_handlers) + + + # This class is part of an EXPERIMENTAL API. +class EventsService(object): + """Missing associated documentation comment in .proto file.""" + + @staticmethod + def Push(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, + '/EventsService/Push', + events__pb2.PushEventRequest.SerializeToString, + events__pb2.Event.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def BulkPush(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, + '/EventsService/BulkPush', + events__pb2.BulkPushEventRequest.SerializeToString, + events__pb2.Events.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def ReplaySingleEvent(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, + '/EventsService/ReplaySingleEvent', + events__pb2.ReplayEventRequest.SerializeToString, + events__pb2.Event.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def PutLog(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, + '/EventsService/PutLog', + events__pb2.PutLogRequest.SerializeToString, + events__pb2.PutLogResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def PutStreamEvent(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, + '/EventsService/PutStreamEvent', + events__pb2.PutStreamEventRequest.SerializeToString, + events__pb2.PutStreamEventResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) -- cgit v1.2.3