diff --git a/backend/orchestrator/common_pb2.py b/backend/orchestrator/common_pb2.py index 160778f6d..42e92cda1 100644 --- a/backend/orchestrator/common_pb2.py +++ b/backend/orchestrator/common_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: common.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'common.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -18,10 +29,9 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'common_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' _globals['_ASSETKIND']._serialized_start=303 _globals['_ASSETKIND']._serialized_end=621 _globals['_SORTORDER']._serialized_start=623 diff --git a/backend/orchestrator/common_pb2_grpc.py b/backend/orchestrator/common_pb2_grpc.py index 2daafffeb..b825388cc 100644 --- a/backend/orchestrator/common_pb2_grpc.py +++ b/backend/orchestrator/common_pb2_grpc.py @@ -1,4 +1,24 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings + +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in common_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}.' + ) diff --git a/backend/orchestrator/computeplan_pb2.py b/backend/orchestrator/computeplan_pb2.py index c3ff76ab9..3da4d5b44 100644 --- a/backend/orchestrator/computeplan_pb2.py +++ b/backend/orchestrator/computeplan_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: computeplan.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'computeplan.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -19,14 +30,13 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'computeplan_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' - _COMPUTEPLAN_METADATAENTRY._options = None - _COMPUTEPLAN_METADATAENTRY._serialized_options = b'8\001' - _NEWCOMPUTEPLAN_METADATAENTRY._options = None - _NEWCOMPUTEPLAN_METADATAENTRY._serialized_options = b'8\001' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' + _globals['_COMPUTEPLAN_METADATAENTRY']._loaded_options = None + _globals['_COMPUTEPLAN_METADATAENTRY']._serialized_options = b'8\001' + _globals['_NEWCOMPUTEPLAN_METADATAENTRY']._loaded_options = None + _globals['_NEWCOMPUTEPLAN_METADATAENTRY']._serialized_options = b'8\001' _globals['_COMPUTEPLANACTION']._serialized_start=1329 _globals['_COMPUTEPLANACTION']._serialized_end=1399 _globals['_COMPUTEPLAN']._serialized_start=69 diff --git a/backend/orchestrator/computeplan_pb2_grpc.py b/backend/orchestrator/computeplan_pb2_grpc.py index 6ab7e2e3e..97f822da0 100644 --- a/backend/orchestrator/computeplan_pb2_grpc.py +++ b/backend/orchestrator/computeplan_pb2_grpc.py @@ -1,9 +1,29 @@ # 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 computeplan_pb2 as computeplan__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in computeplan_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}.' + ) + class ComputePlanServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,32 +38,32 @@ def __init__(self, channel): '/orchestrator.ComputePlanService/RegisterPlan', request_serializer=computeplan__pb2.NewComputePlan.SerializeToString, response_deserializer=computeplan__pb2.ComputePlan.FromString, - ) + _registered_method=True) self.GetPlan = channel.unary_unary( '/orchestrator.ComputePlanService/GetPlan', request_serializer=computeplan__pb2.GetComputePlanParam.SerializeToString, response_deserializer=computeplan__pb2.ComputePlan.FromString, - ) + _registered_method=True) self.ApplyPlanAction = channel.unary_unary( '/orchestrator.ComputePlanService/ApplyPlanAction', request_serializer=computeplan__pb2.ApplyPlanActionParam.SerializeToString, response_deserializer=computeplan__pb2.ApplyPlanActionResponse.FromString, - ) + _registered_method=True) self.QueryPlans = channel.unary_unary( '/orchestrator.ComputePlanService/QueryPlans', request_serializer=computeplan__pb2.QueryPlansParam.SerializeToString, response_deserializer=computeplan__pb2.QueryPlansResponse.FromString, - ) + _registered_method=True) self.UpdatePlan = channel.unary_unary( '/orchestrator.ComputePlanService/UpdatePlan', request_serializer=computeplan__pb2.UpdateComputePlanParam.SerializeToString, response_deserializer=computeplan__pb2.UpdateComputePlanResponse.FromString, - ) + _registered_method=True) self.IsPlanRunning = channel.unary_unary( '/orchestrator.ComputePlanService/IsPlanRunning', request_serializer=computeplan__pb2.IsPlanRunningParam.SerializeToString, response_deserializer=computeplan__pb2.IsPlanRunningResponse.FromString, - ) + _registered_method=True) class ComputePlanServiceServicer(object): @@ -122,6 +142,7 @@ def add_ComputePlanServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'orchestrator.ComputePlanService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('orchestrator.ComputePlanService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -139,11 +160,21 @@ def RegisterPlan(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ComputePlanService/RegisterPlan', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ComputePlanService/RegisterPlan', computeplan__pb2.NewComputePlan.SerializeToString, computeplan__pb2.ComputePlan.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def GetPlan(request, @@ -156,11 +187,21 @@ def GetPlan(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ComputePlanService/GetPlan', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ComputePlanService/GetPlan', computeplan__pb2.GetComputePlanParam.SerializeToString, computeplan__pb2.ComputePlan.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def ApplyPlanAction(request, @@ -173,11 +214,21 @@ def ApplyPlanAction(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ComputePlanService/ApplyPlanAction', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ComputePlanService/ApplyPlanAction', computeplan__pb2.ApplyPlanActionParam.SerializeToString, computeplan__pb2.ApplyPlanActionResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def QueryPlans(request, @@ -190,11 +241,21 @@ def QueryPlans(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ComputePlanService/QueryPlans', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ComputePlanService/QueryPlans', computeplan__pb2.QueryPlansParam.SerializeToString, computeplan__pb2.QueryPlansResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def UpdatePlan(request, @@ -207,11 +268,21 @@ def UpdatePlan(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ComputePlanService/UpdatePlan', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ComputePlanService/UpdatePlan', computeplan__pb2.UpdateComputePlanParam.SerializeToString, computeplan__pb2.UpdateComputePlanResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def IsPlanRunning(request, @@ -224,8 +295,18 @@ def IsPlanRunning(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ComputePlanService/IsPlanRunning', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ComputePlanService/IsPlanRunning', computeplan__pb2.IsPlanRunningParam.SerializeToString, computeplan__pb2.IsPlanRunningResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/backend/orchestrator/computetask_pb2.py b/backend/orchestrator/computetask_pb2.py index 1a6240d47..9e74fa7f5 100644 --- a/backend/orchestrator/computetask_pb2.py +++ b/backend/orchestrator/computetask_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: computetask.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'computetask.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -23,18 +34,17 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'computetask_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' - _COMPUTETASK_METADATAENTRY._options = None - _COMPUTETASK_METADATAENTRY._serialized_options = b'8\001' - _COMPUTETASK_OUTPUTSENTRY._options = None - _COMPUTETASK_OUTPUTSENTRY._serialized_options = b'8\001' - _NEWCOMPUTETASK_METADATAENTRY._options = None - _NEWCOMPUTETASK_METADATAENTRY._serialized_options = b'8\001' - _NEWCOMPUTETASK_OUTPUTSENTRY._options = None - _NEWCOMPUTETASK_OUTPUTSENTRY._serialized_options = b'8\001' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' + _globals['_COMPUTETASK_METADATAENTRY']._loaded_options = None + _globals['_COMPUTETASK_METADATAENTRY']._serialized_options = b'8\001' + _globals['_COMPUTETASK_OUTPUTSENTRY']._loaded_options = None + _globals['_COMPUTETASK_OUTPUTSENTRY']._serialized_options = b'8\001' + _globals['_NEWCOMPUTETASK_METADATAENTRY']._loaded_options = None + _globals['_NEWCOMPUTETASK_METADATAENTRY']._serialized_options = b'8\001' + _globals['_NEWCOMPUTETASK_OUTPUTSENTRY']._loaded_options = None + _globals['_NEWCOMPUTETASK_OUTPUTSENTRY']._serialized_options = b'8\001' _globals['_COMPUTETASKSTATUS']._serialized_start=2970 _globals['_COMPUTETASKSTATUS']._serialized_end=3221 _globals['_COMPUTETASKACTION']._serialized_start=3224 diff --git a/backend/orchestrator/computetask_pb2_grpc.py b/backend/orchestrator/computetask_pb2_grpc.py index fd19bbbbc..e7e2202d3 100644 --- a/backend/orchestrator/computetask_pb2_grpc.py +++ b/backend/orchestrator/computetask_pb2_grpc.py @@ -1,9 +1,29 @@ # 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 computetask_pb2 as computetask__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in computetask_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}.' + ) + class ComputeTaskServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,32 +38,32 @@ def __init__(self, channel): '/orchestrator.ComputeTaskService/RegisterTasks', request_serializer=computetask__pb2.RegisterTasksParam.SerializeToString, response_deserializer=computetask__pb2.RegisterTasksResponse.FromString, - ) + _registered_method=True) self.QueryTasks = channel.unary_unary( '/orchestrator.ComputeTaskService/QueryTasks', request_serializer=computetask__pb2.QueryTasksParam.SerializeToString, response_deserializer=computetask__pb2.QueryTasksResponse.FromString, - ) + _registered_method=True) self.GetTask = channel.unary_unary( '/orchestrator.ComputeTaskService/GetTask', request_serializer=computetask__pb2.GetTaskParam.SerializeToString, response_deserializer=computetask__pb2.ComputeTask.FromString, - ) + _registered_method=True) self.ApplyTaskAction = channel.unary_unary( '/orchestrator.ComputeTaskService/ApplyTaskAction', request_serializer=computetask__pb2.ApplyTaskActionParam.SerializeToString, response_deserializer=computetask__pb2.ApplyTaskActionResponse.FromString, - ) + _registered_method=True) self.GetTaskInputAssets = channel.unary_unary( '/orchestrator.ComputeTaskService/GetTaskInputAssets', request_serializer=computetask__pb2.GetTaskInputAssetsParam.SerializeToString, response_deserializer=computetask__pb2.GetTaskInputAssetsResponse.FromString, - ) + _registered_method=True) self.DisableOutput = channel.unary_unary( '/orchestrator.ComputeTaskService/DisableOutput', request_serializer=computetask__pb2.DisableOutputParam.SerializeToString, response_deserializer=computetask__pb2.DisableOutputResponse.FromString, - ) + _registered_method=True) class ComputeTaskServiceServicer(object): @@ -122,6 +142,7 @@ def add_ComputeTaskServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'orchestrator.ComputeTaskService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('orchestrator.ComputeTaskService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -139,11 +160,21 @@ def RegisterTasks(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ComputeTaskService/RegisterTasks', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ComputeTaskService/RegisterTasks', computetask__pb2.RegisterTasksParam.SerializeToString, computetask__pb2.RegisterTasksResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def QueryTasks(request, @@ -156,11 +187,21 @@ def QueryTasks(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ComputeTaskService/QueryTasks', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ComputeTaskService/QueryTasks', computetask__pb2.QueryTasksParam.SerializeToString, computetask__pb2.QueryTasksResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def GetTask(request, @@ -173,11 +214,21 @@ def GetTask(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ComputeTaskService/GetTask', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ComputeTaskService/GetTask', computetask__pb2.GetTaskParam.SerializeToString, computetask__pb2.ComputeTask.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def ApplyTaskAction(request, @@ -190,11 +241,21 @@ def ApplyTaskAction(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ComputeTaskService/ApplyTaskAction', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ComputeTaskService/ApplyTaskAction', computetask__pb2.ApplyTaskActionParam.SerializeToString, computetask__pb2.ApplyTaskActionResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def GetTaskInputAssets(request, @@ -207,11 +268,21 @@ def GetTaskInputAssets(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ComputeTaskService/GetTaskInputAssets', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ComputeTaskService/GetTaskInputAssets', computetask__pb2.GetTaskInputAssetsParam.SerializeToString, computetask__pb2.GetTaskInputAssetsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def DisableOutput(request, @@ -224,8 +295,18 @@ def DisableOutput(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ComputeTaskService/DisableOutput', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ComputeTaskService/DisableOutput', computetask__pb2.DisableOutputParam.SerializeToString, computetask__pb2.DisableOutputResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/backend/orchestrator/datamanager_pb2.py b/backend/orchestrator/datamanager_pb2.py index 649fde270..0848c65c6 100644 --- a/backend/orchestrator/datamanager_pb2.py +++ b/backend/orchestrator/datamanager_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: datamanager.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'datamanager.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -20,14 +31,13 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'datamanager_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' - _DATAMANAGER_METADATAENTRY._options = None - _DATAMANAGER_METADATAENTRY._serialized_options = b'8\001' - _NEWDATAMANAGER_METADATAENTRY._options = None - _NEWDATAMANAGER_METADATAENTRY._serialized_options = b'8\001' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' + _globals['_DATAMANAGER_METADATAENTRY']._loaded_options = None + _globals['_DATAMANAGER_METADATAENTRY']._serialized_options = b'8\001' + _globals['_NEWDATAMANAGER_METADATAENTRY']._loaded_options = None + _globals['_NEWDATAMANAGER_METADATAENTRY']._serialized_options = b'8\001' _globals['_DATAMANAGER']._serialized_start=83 _globals['_DATAMANAGER']._serialized_end=501 _globals['_DATAMANAGER_METADATAENTRY']._serialized_start=454 diff --git a/backend/orchestrator/datamanager_pb2_grpc.py b/backend/orchestrator/datamanager_pb2_grpc.py index 2850a803e..8150df206 100644 --- a/backend/orchestrator/datamanager_pb2_grpc.py +++ b/backend/orchestrator/datamanager_pb2_grpc.py @@ -1,9 +1,29 @@ # 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 datamanager_pb2 as datamanager__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in datamanager_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}.' + ) + class DataManagerServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,22 +38,22 @@ def __init__(self, channel): '/orchestrator.DataManagerService/RegisterDataManager', request_serializer=datamanager__pb2.NewDataManager.SerializeToString, response_deserializer=datamanager__pb2.DataManager.FromString, - ) + _registered_method=True) self.GetDataManager = channel.unary_unary( '/orchestrator.DataManagerService/GetDataManager', request_serializer=datamanager__pb2.GetDataManagerParam.SerializeToString, response_deserializer=datamanager__pb2.DataManager.FromString, - ) + _registered_method=True) self.QueryDataManagers = channel.unary_unary( '/orchestrator.DataManagerService/QueryDataManagers', request_serializer=datamanager__pb2.QueryDataManagersParam.SerializeToString, response_deserializer=datamanager__pb2.QueryDataManagersResponse.FromString, - ) + _registered_method=True) self.UpdateDataManager = channel.unary_unary( '/orchestrator.DataManagerService/UpdateDataManager', request_serializer=datamanager__pb2.UpdateDataManagerParam.SerializeToString, response_deserializer=datamanager__pb2.UpdateDataManagerResponse.FromString, - ) + _registered_method=True) class DataManagerServiceServicer(object): @@ -90,6 +110,7 @@ def add_DataManagerServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'orchestrator.DataManagerService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('orchestrator.DataManagerService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -107,11 +128,21 @@ def RegisterDataManager(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.DataManagerService/RegisterDataManager', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.DataManagerService/RegisterDataManager', datamanager__pb2.NewDataManager.SerializeToString, datamanager__pb2.DataManager.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def GetDataManager(request, @@ -124,11 +155,21 @@ def GetDataManager(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.DataManagerService/GetDataManager', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.DataManagerService/GetDataManager', datamanager__pb2.GetDataManagerParam.SerializeToString, datamanager__pb2.DataManager.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def QueryDataManagers(request, @@ -141,11 +182,21 @@ def QueryDataManagers(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.DataManagerService/QueryDataManagers', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.DataManagerService/QueryDataManagers', datamanager__pb2.QueryDataManagersParam.SerializeToString, datamanager__pb2.QueryDataManagersResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def UpdateDataManager(request, @@ -158,8 +209,18 @@ def UpdateDataManager(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.DataManagerService/UpdateDataManager', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.DataManagerService/UpdateDataManager', datamanager__pb2.UpdateDataManagerParam.SerializeToString, datamanager__pb2.UpdateDataManagerResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/backend/orchestrator/datasample_pb2.py b/backend/orchestrator/datasample_pb2.py index 5e42cacb8..c4a108af3 100644 --- a/backend/orchestrator/datasample_pb2.py +++ b/backend/orchestrator/datasample_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: datasample.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'datasample.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -19,10 +30,9 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'datasample_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' _globals['_DATASAMPLE']._serialized_start=68 _globals['_DATASAMPLE']._serialized_end=223 _globals['_NEWDATASAMPLE']._serialized_start=225 diff --git a/backend/orchestrator/datasample_pb2_grpc.py b/backend/orchestrator/datasample_pb2_grpc.py index f9a397f2c..47fbd2496 100644 --- a/backend/orchestrator/datasample_pb2_grpc.py +++ b/backend/orchestrator/datasample_pb2_grpc.py @@ -1,9 +1,29 @@ # 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 datasample_pb2 as datasample__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in datasample_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}.' + ) + class DataSampleServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,22 +38,22 @@ def __init__(self, channel): '/orchestrator.DataSampleService/RegisterDataSamples', request_serializer=datasample__pb2.RegisterDataSamplesParam.SerializeToString, response_deserializer=datasample__pb2.RegisterDataSamplesResponse.FromString, - ) + _registered_method=True) self.UpdateDataSamples = channel.unary_unary( '/orchestrator.DataSampleService/UpdateDataSamples', request_serializer=datasample__pb2.UpdateDataSamplesParam.SerializeToString, response_deserializer=datasample__pb2.UpdateDataSamplesResponse.FromString, - ) + _registered_method=True) self.QueryDataSamples = channel.unary_unary( '/orchestrator.DataSampleService/QueryDataSamples', request_serializer=datasample__pb2.QueryDataSamplesParam.SerializeToString, response_deserializer=datasample__pb2.QueryDataSamplesResponse.FromString, - ) + _registered_method=True) self.GetDataSample = channel.unary_unary( '/orchestrator.DataSampleService/GetDataSample', request_serializer=datasample__pb2.GetDataSampleParam.SerializeToString, response_deserializer=datasample__pb2.DataSample.FromString, - ) + _registered_method=True) class DataSampleServiceServicer(object): @@ -90,6 +110,7 @@ def add_DataSampleServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'orchestrator.DataSampleService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('orchestrator.DataSampleService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -107,11 +128,21 @@ def RegisterDataSamples(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.DataSampleService/RegisterDataSamples', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.DataSampleService/RegisterDataSamples', datasample__pb2.RegisterDataSamplesParam.SerializeToString, datasample__pb2.RegisterDataSamplesResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def UpdateDataSamples(request, @@ -124,11 +155,21 @@ def UpdateDataSamples(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.DataSampleService/UpdateDataSamples', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.DataSampleService/UpdateDataSamples', datasample__pb2.UpdateDataSamplesParam.SerializeToString, datasample__pb2.UpdateDataSamplesResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def QueryDataSamples(request, @@ -141,11 +182,21 @@ def QueryDataSamples(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.DataSampleService/QueryDataSamples', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.DataSampleService/QueryDataSamples', datasample__pb2.QueryDataSamplesParam.SerializeToString, datasample__pb2.QueryDataSamplesResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def GetDataSample(request, @@ -158,8 +209,18 @@ def GetDataSample(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.DataSampleService/GetDataSample', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.DataSampleService/GetDataSample', datasample__pb2.GetDataSampleParam.SerializeToString, datasample__pb2.DataSample.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/backend/orchestrator/dataset_pb2.py b/backend/orchestrator/dataset_pb2.py index 4a9843bfa..1d3566f27 100644 --- a/backend/orchestrator/dataset_pb2.py +++ b/backend/orchestrator/dataset_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: dataset.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'dataset.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -19,10 +30,9 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'dataset_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' _globals['_DATASET']._serialized_start=51 _globals['_DATASET']._serialized_end=194 _globals['_GETDATASETPARAM']._serialized_start=196 diff --git a/backend/orchestrator/dataset_pb2_grpc.py b/backend/orchestrator/dataset_pb2_grpc.py index b2fa56882..6b2a2a988 100644 --- a/backend/orchestrator/dataset_pb2_grpc.py +++ b/backend/orchestrator/dataset_pb2_grpc.py @@ -1,9 +1,29 @@ # 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 dataset_pb2 as dataset__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in dataset_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}.' + ) + class DatasetServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,7 +38,7 @@ def __init__(self, channel): '/orchestrator.DatasetService/GetDataset', request_serializer=dataset__pb2.GetDatasetParam.SerializeToString, response_deserializer=dataset__pb2.Dataset.FromString, - ) + _registered_method=True) class DatasetServiceServicer(object): @@ -42,6 +62,7 @@ def add_DatasetServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'orchestrator.DatasetService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('orchestrator.DatasetService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -59,8 +80,18 @@ def GetDataset(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.DatasetService/GetDataset', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.DatasetService/GetDataset', dataset__pb2.GetDatasetParam.SerializeToString, dataset__pb2.Dataset.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/backend/orchestrator/event_pb2.py b/backend/orchestrator/event_pb2.py index 0d7b2d6bb..0a9adb540 100644 --- a/backend/orchestrator/event_pb2.py +++ b/backend/orchestrator/event_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: event.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'event.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -30,14 +41,13 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'event_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' - _EVENT_METADATAENTRY._options = None - _EVENT_METADATAENTRY._serialized_options = b'8\001' - _EVENTQUERYFILTER_METADATAENTRY._options = None - _EVENTQUERYFILTER_METADATAENTRY._serialized_options = b'8\001' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' + _globals['_EVENT_METADATAENTRY']._loaded_options = None + _globals['_EVENT_METADATAENTRY']._serialized_options = b'8\001' + _globals['_EVENTQUERYFILTER_METADATAENTRY']._loaded_options = None + _globals['_EVENTQUERYFILTER_METADATAENTRY']._serialized_options = b'8\001' _globals['_EVENTKIND']._serialized_start=1744 _globals['_EVENTKIND']._serialized_end=1850 _globals['_EVENT']._serialized_start=259 diff --git a/backend/orchestrator/event_pb2_grpc.py b/backend/orchestrator/event_pb2_grpc.py index 25050a6b3..b87e8b290 100644 --- a/backend/orchestrator/event_pb2_grpc.py +++ b/backend/orchestrator/event_pb2_grpc.py @@ -1,9 +1,29 @@ # 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 event_pb2 as event__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in event_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}.' + ) + class EventServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,12 +38,12 @@ def __init__(self, channel): '/orchestrator.EventService/QueryEvents', request_serializer=event__pb2.QueryEventsParam.SerializeToString, response_deserializer=event__pb2.QueryEventsResponse.FromString, - ) + _registered_method=True) self.SubscribeToEvents = channel.unary_stream( '/orchestrator.EventService/SubscribeToEvents', request_serializer=event__pb2.SubscribeToEventsParam.SerializeToString, response_deserializer=event__pb2.Event.FromString, - ) + _registered_method=True) class EventServiceServicer(object): @@ -58,6 +78,7 @@ def add_EventServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'orchestrator.EventService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('orchestrator.EventService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -75,11 +96,21 @@ def QueryEvents(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.EventService/QueryEvents', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.EventService/QueryEvents', event__pb2.QueryEventsParam.SerializeToString, event__pb2.QueryEventsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def SubscribeToEvents(request, @@ -92,8 +123,18 @@ def SubscribeToEvents(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream(request, target, '/orchestrator.EventService/SubscribeToEvents', + return grpc.experimental.unary_stream( + request, + target, + '/orchestrator.EventService/SubscribeToEvents', event__pb2.SubscribeToEventsParam.SerializeToString, event__pb2.Event.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/backend/orchestrator/failure_report_pb2.py b/backend/orchestrator/failure_report_pb2.py index 1d2f14133..7b36909e4 100644 --- a/backend/orchestrator/failure_report_pb2.py +++ b/backend/orchestrator/failure_report_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: failure_report.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'failure_report.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -20,10 +31,9 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'failure_report_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' _globals['_ERRORTYPE']._serialized_start=562 _globals['_ERRORTYPE']._serialized_end=674 _globals['_FAILEDASSETKIND']._serialized_start=676 diff --git a/backend/orchestrator/failure_report_pb2_grpc.py b/backend/orchestrator/failure_report_pb2_grpc.py index c7b6c8230..f6876fdba 100644 --- a/backend/orchestrator/failure_report_pb2_grpc.py +++ b/backend/orchestrator/failure_report_pb2_grpc.py @@ -1,9 +1,29 @@ # 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 failure_report_pb2 as failure__report__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in failure_report_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}.' + ) + class FailureReportServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,12 +38,12 @@ def __init__(self, channel): '/orchestrator.FailureReportService/RegisterFailureReport', request_serializer=failure__report__pb2.NewFailureReport.SerializeToString, response_deserializer=failure__report__pb2.FailureReport.FromString, - ) + _registered_method=True) self.GetFailureReport = channel.unary_unary( '/orchestrator.FailureReportService/GetFailureReport', request_serializer=failure__report__pb2.GetFailureReportParam.SerializeToString, response_deserializer=failure__report__pb2.FailureReport.FromString, - ) + _registered_method=True) class FailureReportServiceServicer(object): @@ -58,6 +78,7 @@ def add_FailureReportServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'orchestrator.FailureReportService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('orchestrator.FailureReportService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -75,11 +96,21 @@ def RegisterFailureReport(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.FailureReportService/RegisterFailureReport', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.FailureReportService/RegisterFailureReport', failure__report__pb2.NewFailureReport.SerializeToString, failure__report__pb2.FailureReport.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def GetFailureReport(request, @@ -92,8 +123,18 @@ def GetFailureReport(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.FailureReportService/GetFailureReport', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.FailureReportService/GetFailureReport', failure__report__pb2.GetFailureReportParam.SerializeToString, failure__report__pb2.FailureReport.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/backend/orchestrator/function_pb2.py b/backend/orchestrator/function_pb2.py index 8ee19f440..efddd3818 100644 --- a/backend/orchestrator/function_pb2.py +++ b/backend/orchestrator/function_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: function.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'function.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -20,22 +31,21 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'function_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' - _FUNCTION_METADATAENTRY._options = None - _FUNCTION_METADATAENTRY._serialized_options = b'8\001' - _FUNCTION_INPUTSENTRY._options = None - _FUNCTION_INPUTSENTRY._serialized_options = b'8\001' - _FUNCTION_OUTPUTSENTRY._options = None - _FUNCTION_OUTPUTSENTRY._serialized_options = b'8\001' - _NEWFUNCTION_METADATAENTRY._options = None - _NEWFUNCTION_METADATAENTRY._serialized_options = b'8\001' - _NEWFUNCTION_INPUTSENTRY._options = None - _NEWFUNCTION_INPUTSENTRY._serialized_options = b'8\001' - _NEWFUNCTION_OUTPUTSENTRY._options = None - _NEWFUNCTION_OUTPUTSENTRY._serialized_options = b'8\001' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' + _globals['_FUNCTION_METADATAENTRY']._loaded_options = None + _globals['_FUNCTION_METADATAENTRY']._serialized_options = b'8\001' + _globals['_FUNCTION_INPUTSENTRY']._loaded_options = None + _globals['_FUNCTION_INPUTSENTRY']._serialized_options = b'8\001' + _globals['_FUNCTION_OUTPUTSENTRY']._loaded_options = None + _globals['_FUNCTION_OUTPUTSENTRY']._serialized_options = b'8\001' + _globals['_NEWFUNCTION_METADATAENTRY']._loaded_options = None + _globals['_NEWFUNCTION_METADATAENTRY']._serialized_options = b'8\001' + _globals['_NEWFUNCTION_INPUTSENTRY']._loaded_options = None + _globals['_NEWFUNCTION_INPUTSENTRY']._serialized_options = b'8\001' + _globals['_NEWFUNCTION_OUTPUTSENTRY']._loaded_options = None + _globals['_NEWFUNCTION_OUTPUTSENTRY']._serialized_options = b'8\001' _globals['_FUNCTIONACTION']._serialized_start=2076 _globals['_FUNCTIONACTION']._serialized_end=2236 _globals['_FUNCTIONSTATUS']._serialized_start=2239 diff --git a/backend/orchestrator/function_pb2_grpc.py b/backend/orchestrator/function_pb2_grpc.py index b557d15fc..88a138a4c 100644 --- a/backend/orchestrator/function_pb2_grpc.py +++ b/backend/orchestrator/function_pb2_grpc.py @@ -1,9 +1,29 @@ # 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 function_pb2 as function__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in function_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}.' + ) + class FunctionServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,27 +38,27 @@ def __init__(self, channel): '/orchestrator.FunctionService/RegisterFunction', request_serializer=function__pb2.NewFunction.SerializeToString, response_deserializer=function__pb2.Function.FromString, - ) + _registered_method=True) self.GetFunction = channel.unary_unary( '/orchestrator.FunctionService/GetFunction', request_serializer=function__pb2.GetFunctionParam.SerializeToString, response_deserializer=function__pb2.Function.FromString, - ) + _registered_method=True) self.QueryFunctions = channel.unary_unary( '/orchestrator.FunctionService/QueryFunctions', request_serializer=function__pb2.QueryFunctionsParam.SerializeToString, response_deserializer=function__pb2.QueryFunctionsResponse.FromString, - ) + _registered_method=True) self.UpdateFunction = channel.unary_unary( '/orchestrator.FunctionService/UpdateFunction', request_serializer=function__pb2.UpdateFunctionParam.SerializeToString, response_deserializer=function__pb2.UpdateFunctionResponse.FromString, - ) + _registered_method=True) self.ApplyFunctionAction = channel.unary_unary( '/orchestrator.FunctionService/ApplyFunctionAction', request_serializer=function__pb2.ApplyFunctionActionParam.SerializeToString, response_deserializer=function__pb2.ApplyFunctionActionResponse.FromString, - ) + _registered_method=True) class FunctionServiceServicer(object): @@ -106,6 +126,7 @@ def add_FunctionServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'orchestrator.FunctionService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('orchestrator.FunctionService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -123,11 +144,21 @@ def RegisterFunction(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.FunctionService/RegisterFunction', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.FunctionService/RegisterFunction', function__pb2.NewFunction.SerializeToString, function__pb2.Function.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def GetFunction(request, @@ -140,11 +171,21 @@ def GetFunction(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.FunctionService/GetFunction', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.FunctionService/GetFunction', function__pb2.GetFunctionParam.SerializeToString, function__pb2.Function.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def QueryFunctions(request, @@ -157,11 +198,21 @@ def QueryFunctions(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.FunctionService/QueryFunctions', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.FunctionService/QueryFunctions', function__pb2.QueryFunctionsParam.SerializeToString, function__pb2.QueryFunctionsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def UpdateFunction(request, @@ -174,11 +225,21 @@ def UpdateFunction(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.FunctionService/UpdateFunction', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.FunctionService/UpdateFunction', function__pb2.UpdateFunctionParam.SerializeToString, function__pb2.UpdateFunctionResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def ApplyFunctionAction(request, @@ -191,8 +252,18 @@ def ApplyFunctionAction(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.FunctionService/ApplyFunctionAction', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.FunctionService/ApplyFunctionAction', function__pb2.ApplyFunctionActionParam.SerializeToString, function__pb2.ApplyFunctionActionResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/backend/orchestrator/info_pb2.py b/backend/orchestrator/info_pb2.py index 58ddead5f..c6cf503bd 100644 --- a/backend/orchestrator/info_pb2.py +++ b/backend/orchestrator/info_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: info.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'info.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -18,10 +29,9 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'info_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' _globals['_QUERYVERSIONPARAM']._serialized_start=28 _globals['_QUERYVERSIONPARAM']._serialized_end=47 _globals['_QUERYVERSIONRESPONSE']._serialized_start=49 diff --git a/backend/orchestrator/info_pb2_grpc.py b/backend/orchestrator/info_pb2_grpc.py index 71e843829..761632d74 100644 --- a/backend/orchestrator/info_pb2_grpc.py +++ b/backend/orchestrator/info_pb2_grpc.py @@ -1,9 +1,29 @@ # 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 info_pb2 as info__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in info_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}.' + ) + class InfoServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,7 +38,7 @@ def __init__(self, channel): '/orchestrator.InfoService/QueryVersion', request_serializer=info__pb2.QueryVersionParam.SerializeToString, response_deserializer=info__pb2.QueryVersionResponse.FromString, - ) + _registered_method=True) class InfoServiceServicer(object): @@ -42,6 +62,7 @@ def add_InfoServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'orchestrator.InfoService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('orchestrator.InfoService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -59,8 +80,18 @@ def QueryVersion(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.InfoService/QueryVersion', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.InfoService/QueryVersion', info__pb2.QueryVersionParam.SerializeToString, info__pb2.QueryVersionResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/backend/orchestrator/model_pb2.py b/backend/orchestrator/model_pb2.py index d15d1d7c9..ee2ecb8af 100644 --- a/backend/orchestrator/model_pb2.py +++ b/backend/orchestrator/model_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: model.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'model.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -20,12 +31,11 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'model_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' - _MODELSERVICE.methods_by_name['RegisterModel']._options = None - _MODELSERVICE.methods_by_name['RegisterModel']._serialized_options = b'\210\002\001' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' + _globals['_MODELSERVICE'].methods_by_name['RegisterModel']._loaded_options = None + _globals['_MODELSERVICE'].methods_by_name['RegisterModel']._serialized_options = b'\210\002\001' _globals['_MODEL']._serialized_start=77 _globals['_MODEL']._serialized_end=297 _globals['_NEWMODEL']._serialized_start=300 diff --git a/backend/orchestrator/model_pb2_grpc.py b/backend/orchestrator/model_pb2_grpc.py index 31ab83b5a..ffb454fc9 100644 --- a/backend/orchestrator/model_pb2_grpc.py +++ b/backend/orchestrator/model_pb2_grpc.py @@ -1,9 +1,29 @@ # 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 model_pb2 as model__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in model_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}.' + ) + class ModelServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,22 +38,22 @@ def __init__(self, channel): '/orchestrator.ModelService/RegisterModel', request_serializer=model__pb2.NewModel.SerializeToString, response_deserializer=model__pb2.Model.FromString, - ) + _registered_method=True) self.RegisterModels = channel.unary_unary( '/orchestrator.ModelService/RegisterModels', request_serializer=model__pb2.RegisterModelsParam.SerializeToString, response_deserializer=model__pb2.RegisterModelsResponse.FromString, - ) + _registered_method=True) self.GetModel = channel.unary_unary( '/orchestrator.ModelService/GetModel', request_serializer=model__pb2.GetModelParam.SerializeToString, response_deserializer=model__pb2.Model.FromString, - ) + _registered_method=True) self.GetComputeTaskOutputModels = channel.unary_unary( '/orchestrator.ModelService/GetComputeTaskOutputModels', request_serializer=model__pb2.GetComputeTaskModelsParam.SerializeToString, response_deserializer=model__pb2.GetComputeTaskModelsResponse.FromString, - ) + _registered_method=True) class ModelServiceServicer(object): @@ -90,6 +110,7 @@ def add_ModelServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'orchestrator.ModelService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('orchestrator.ModelService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -107,11 +128,21 @@ def RegisterModel(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ModelService/RegisterModel', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ModelService/RegisterModel', model__pb2.NewModel.SerializeToString, model__pb2.Model.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def RegisterModels(request, @@ -124,11 +155,21 @@ def RegisterModels(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ModelService/RegisterModels', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ModelService/RegisterModels', model__pb2.RegisterModelsParam.SerializeToString, model__pb2.RegisterModelsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def GetModel(request, @@ -141,11 +182,21 @@ def GetModel(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ModelService/GetModel', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ModelService/GetModel', model__pb2.GetModelParam.SerializeToString, model__pb2.Model.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def GetComputeTaskOutputModels(request, @@ -158,8 +209,18 @@ def GetComputeTaskOutputModels(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ModelService/GetComputeTaskOutputModels', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ModelService/GetComputeTaskOutputModels', model__pb2.GetComputeTaskModelsParam.SerializeToString, model__pb2.GetComputeTaskModelsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/backend/orchestrator/organization_pb2.py b/backend/orchestrator/organization_pb2.py index c9cd83fbe..c3c4894c5 100644 --- a/backend/orchestrator/organization_pb2.py +++ b/backend/orchestrator/organization_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: organization.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'organization.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -19,10 +30,9 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'organization_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' _globals['_ORGANIZATION']._serialized_start=69 _globals['_ORGANIZATION']._serialized_end=163 _globals['_GETALLORGANIZATIONSRESPONSE']._serialized_start=165 diff --git a/backend/orchestrator/organization_pb2_grpc.py b/backend/orchestrator/organization_pb2_grpc.py index 14374d0e0..4fec9cead 100644 --- a/backend/orchestrator/organization_pb2_grpc.py +++ b/backend/orchestrator/organization_pb2_grpc.py @@ -1,9 +1,29 @@ # 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 organization_pb2 as organization__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in organization_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}.' + ) + class OrganizationServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,12 +38,12 @@ def __init__(self, channel): '/orchestrator.OrganizationService/RegisterOrganization', request_serializer=organization__pb2.RegisterOrganizationParam.SerializeToString, response_deserializer=organization__pb2.Organization.FromString, - ) + _registered_method=True) self.GetAllOrganizations = channel.unary_unary( '/orchestrator.OrganizationService/GetAllOrganizations', request_serializer=organization__pb2.GetAllOrganizationsParam.SerializeToString, response_deserializer=organization__pb2.GetAllOrganizationsResponse.FromString, - ) + _registered_method=True) class OrganizationServiceServicer(object): @@ -58,6 +78,7 @@ def add_OrganizationServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'orchestrator.OrganizationService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('orchestrator.OrganizationService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -75,11 +96,21 @@ def RegisterOrganization(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.OrganizationService/RegisterOrganization', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.OrganizationService/RegisterOrganization', organization__pb2.RegisterOrganizationParam.SerializeToString, organization__pb2.Organization.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def GetAllOrganizations(request, @@ -92,8 +123,18 @@ def GetAllOrganizations(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.OrganizationService/GetAllOrganizations', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.OrganizationService/GetAllOrganizations', organization__pb2.GetAllOrganizationsParam.SerializeToString, organization__pb2.GetAllOrganizationsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/backend/orchestrator/performance_pb2.py b/backend/orchestrator/performance_pb2.py index 68a8c6266..ba58559bc 100644 --- a/backend/orchestrator/performance_pb2.py +++ b/backend/orchestrator/performance_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: performance.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'performance.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -19,10 +30,9 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'performance_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' _globals['_NEWPERFORMANCE']._serialized_start=68 _globals['_NEWPERFORMANCE']._serialized_end=177 _globals['_PERFORMANCE']._serialized_start=180 diff --git a/backend/orchestrator/performance_pb2_grpc.py b/backend/orchestrator/performance_pb2_grpc.py index c44a8b56e..1d07a1c77 100644 --- a/backend/orchestrator/performance_pb2_grpc.py +++ b/backend/orchestrator/performance_pb2_grpc.py @@ -1,9 +1,29 @@ # 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 performance_pb2 as performance__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in performance_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}.' + ) + class PerformanceServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,12 +38,12 @@ def __init__(self, channel): '/orchestrator.PerformanceService/RegisterPerformance', request_serializer=performance__pb2.NewPerformance.SerializeToString, response_deserializer=performance__pb2.Performance.FromString, - ) + _registered_method=True) self.QueryPerformances = channel.unary_unary( '/orchestrator.PerformanceService/QueryPerformances', request_serializer=performance__pb2.QueryPerformancesParam.SerializeToString, response_deserializer=performance__pb2.QueryPerformancesResponse.FromString, - ) + _registered_method=True) class PerformanceServiceServicer(object): @@ -58,6 +78,7 @@ def add_PerformanceServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'orchestrator.PerformanceService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('orchestrator.PerformanceService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -75,11 +96,21 @@ def RegisterPerformance(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.PerformanceService/RegisterPerformance', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.PerformanceService/RegisterPerformance', performance__pb2.NewPerformance.SerializeToString, performance__pb2.Performance.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def QueryPerformances(request, @@ -92,8 +123,18 @@ def QueryPerformances(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.PerformanceService/QueryPerformances', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.PerformanceService/QueryPerformances', performance__pb2.QueryPerformancesParam.SerializeToString, performance__pb2.QueryPerformancesResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/backend/orchestrator/profiling_pb2.py b/backend/orchestrator/profiling_pb2.py index 491eb887e..53d9c3005 100644 --- a/backend/orchestrator/profiling_pb2.py +++ b/backend/orchestrator/profiling_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: profiling.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'profiling.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -19,10 +30,9 @@ _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'profiling_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'Z)github.com/substra/orchestrator/lib/asset' _globals['_PROFILINGSTEP']._serialized_start=62 _globals['_PROFILINGSTEP']._serialized_end=128 _globals['_PROFILINGSERVICE']._serialized_start=130 diff --git a/backend/orchestrator/profiling_pb2_grpc.py b/backend/orchestrator/profiling_pb2_grpc.py index c94560763..3ce95d784 100644 --- a/backend/orchestrator/profiling_pb2_grpc.py +++ b/backend/orchestrator/profiling_pb2_grpc.py @@ -1,10 +1,30 @@ # 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 google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2 from . import profiling_pb2 as profiling__pb2 +GRPC_GENERATED_VERSION = '1.66.1' +GRPC_VERSION = grpc.__version__ +_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: + raise RuntimeError( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in profiling_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}.' + ) + class ProfilingServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -19,7 +39,7 @@ def __init__(self, channel): '/orchestrator.ProfilingService/RegisterProfilingStep', request_serializer=profiling__pb2.ProfilingStep.SerializeToString, response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, - ) + _registered_method=True) class ProfilingServiceServicer(object): @@ -43,6 +63,7 @@ def add_ProfilingServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'orchestrator.ProfilingService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('orchestrator.ProfilingService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -60,8 +81,18 @@ def RegisterProfilingStep(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/orchestrator.ProfilingService/RegisterProfilingStep', + return grpc.experimental.unary_unary( + request, + target, + '/orchestrator.ProfilingService/RegisterProfilingStep', profiling__pb2.ProfilingStep.SerializeToString, google_dot_protobuf_dot_empty__pb2.Empty.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True)