diff --git a/fedn/network/grpc/fedn_pb2.py b/fedn/network/grpc/fedn_pb2.py index 09ecdec36..2e23c4b32 100644 --- a/fedn/network/grpc/fedn_pb2.py +++ b/fedn/network/grpc/fedn_pb2.py @@ -1,12 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! -# source: fedn/network/grpc/fedn.proto -# Protobuf Python Version: 4.25.0 +# NO CHECKED-IN PROTOBUF GENCODE +# source: network/grpc/fedn.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, + '', + 'network/grpc/fedn.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -15,109 +25,109 @@ from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1c\x66\x65\x64n/network/grpc/fedn.proto\x12\x04\x66\x65\x64n\x1a\x1fgoogle/protobuf/timestamp.proto\":\n\x08Response\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x10\n\x08response\x18\x02 \x01(\t\"\xbc\x02\n\x06Status\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x0e\n\x06status\x18\x02 \x01(\t\x12(\n\tlog_level\x18\x03 \x01(\x0e\x32\x15.fedn.Status.LogLevel\x12\x0c\n\x04\x64\x61ta\x18\x04 \x01(\t\x12\x16\n\x0e\x63orrelation_id\x18\x05 \x01(\t\x12-\n\ttimestamp\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x1e\n\x04type\x18\x07 \x01(\x0e\x32\x10.fedn.StatusType\x12\r\n\x05\x65xtra\x18\x08 \x01(\t\x12\x12\n\nsession_id\x18\t \x01(\t\"B\n\x08LogLevel\x12\x08\n\x04INFO\x10\x00\x12\t\n\x05\x44\x45\x42UG\x10\x01\x12\x0b\n\x07WARNING\x10\x02\x12\t\n\x05\x45RROR\x10\x03\x12\t\n\x05\x41UDIT\x10\x04\"\xd8\x01\n\x0bTaskRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x10\n\x08model_id\x18\x03 \x01(\t\x12\x0c\n\x04\x64\x61ta\x18\x04 \x01(\t\x12\x16\n\x0e\x63orrelation_id\x18\x05 \x01(\t\x12\x11\n\ttimestamp\x18\x06 \x01(\t\x12\x0c\n\x04meta\x18\x07 \x01(\t\x12\x12\n\nsession_id\x18\x08 \x01(\t\x12\x1e\n\x04type\x18\t \x01(\x0e\x32\x10.fedn.StatusType\"\xbf\x01\n\x0bModelUpdate\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x10\n\x08model_id\x18\x03 \x01(\t\x12\x17\n\x0fmodel_update_id\x18\x04 \x01(\t\x12\x16\n\x0e\x63orrelation_id\x18\x05 \x01(\t\x12\x11\n\ttimestamp\x18\x06 \x01(\t\x12\x0c\n\x04meta\x18\x07 \x01(\t\x12\x0e\n\x06\x63onfig\x18\x08 \x01(\t\"\xd8\x01\n\x0fModelValidation\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x10\n\x08model_id\x18\x03 \x01(\t\x12\x0c\n\x04\x64\x61ta\x18\x04 \x01(\t\x12\x16\n\x0e\x63orrelation_id\x18\x05 \x01(\t\x12-\n\ttimestamp\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x0c\n\x04meta\x18\x07 \x01(\t\x12\x12\n\nsession_id\x18\x08 \x01(\t\"\xdb\x01\n\x0fModelPrediction\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x10\n\x08model_id\x18\x03 \x01(\t\x12\x0c\n\x04\x64\x61ta\x18\x04 \x01(\t\x12\x16\n\x0e\x63orrelation_id\x18\x05 \x01(\t\x12-\n\ttimestamp\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x0c\n\x04meta\x18\x07 \x01(\t\x12\x15\n\rprediction_id\x18\x08 \x01(\t\"\x89\x01\n\x0cModelRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x0c\n\x04\x64\x61ta\x18\x03 \x01(\x0c\x12\n\n\x02id\x18\x04 \x01(\t\x12!\n\x06status\x18\x05 \x01(\x0e\x32\x11.fedn.ModelStatus\"]\n\rModelResponse\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\x12\n\n\x02id\x18\x02 \x01(\t\x12!\n\x06status\x18\x03 \x01(\x0e\x32\x11.fedn.ModelStatus\x12\x0f\n\x07message\x18\x04 \x01(\t\"U\n\x15GetGlobalModelRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\"h\n\x16GetGlobalModelResponse\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x10\n\x08model_id\x18\x03 \x01(\t\")\n\tHeartbeat\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\"W\n\x16\x43lientAvailableMessage\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\t\x12\x11\n\ttimestamp\x18\x03 \x01(\t\"P\n\x12ListClientsRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1c\n\x07\x63hannel\x18\x02 \x01(\x0e\x32\x0b.fedn.Queue\"*\n\nClientList\x12\x1c\n\x06\x63lient\x18\x01 \x03(\x0b\x32\x0c.fedn.Client\"C\n\x06\x43lient\x12\x18\n\x04role\x18\x01 \x01(\x0e\x32\n.fedn.Role\x12\x0c\n\x04name\x18\x02 \x01(\t\x12\x11\n\tclient_id\x18\x03 \x01(\t\"m\n\x0fReassignRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x0e\n\x06server\x18\x03 \x01(\t\x12\x0c\n\x04port\x18\x04 \x01(\r\"c\n\x10ReconnectRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x11\n\treconnect\x18\x03 \x01(\r\"\'\n\tParameter\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t\"T\n\x0e\x43ontrolRequest\x12\x1e\n\x07\x63ommand\x18\x01 \x01(\x0e\x32\r.fedn.Command\x12\"\n\tparameter\x18\x02 \x03(\x0b\x32\x0f.fedn.Parameter\"F\n\x0f\x43ontrolResponse\x12\x0f\n\x07message\x18\x01 \x01(\t\x12\"\n\tparameter\x18\x02 \x03(\x0b\x32\x0f.fedn.Parameter\"\x13\n\x11\x43onnectionRequest\"<\n\x12\x43onnectionResponse\x12&\n\x06status\x18\x01 \x01(\x0e\x32\x16.fedn.ConnectionStatus\"1\n\x18ProvidedFunctionsRequest\x12\x15\n\rfunction_code\x18\x01 \x01(\t\"\xac\x01\n\x19ProvidedFunctionsResponse\x12T\n\x13\x61vailable_functions\x18\x01 \x03(\x0b\x32\x37.fedn.ProvidedFunctionsResponse.AvailableFunctionsEntry\x1a\x39\n\x17\x41vailableFunctionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x08:\x02\x38\x01\"#\n\x13\x43lientConfigRequest\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\"/\n\x14\x43lientConfigResponse\x12\x17\n\x0f\x63lient_settings\x18\x01 \x01(\t\",\n\x16\x43lientSelectionRequest\x12\x12\n\nclient_ids\x18\x01 \x01(\t\"-\n\x17\x43lientSelectionResponse\x12\x12\n\nclient_ids\x18\x01 \x01(\t\"8\n\x11\x43lientMetaRequest\x12\x10\n\x08metadata\x18\x01 \x01(\t\x12\x11\n\tclient_id\x18\x02 \x01(\t\"$\n\x12\x43lientMetaResponse\x12\x0e\n\x06status\x18\x01 \x01(\t\"-\n\x11StoreModelRequest\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\x12\n\n\x02id\x18\x02 \x01(\t\"$\n\x12StoreModelResponse\x12\x0e\n\x06status\x18\x01 \x01(\t\"\'\n\x12\x41ggregationRequest\x12\x11\n\taggregate\x18\x01 \x01(\t\"#\n\x13\x41ggregationResponse\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c*\x8b\x01\n\nStatusType\x12\x07\n\x03LOG\x10\x00\x12\x18\n\x14MODEL_UPDATE_REQUEST\x10\x01\x12\x10\n\x0cMODEL_UPDATE\x10\x02\x12\x1c\n\x18MODEL_VALIDATION_REQUEST\x10\x03\x12\x14\n\x10MODEL_VALIDATION\x10\x04\x12\x14\n\x10MODEL_PREDICTION\x10\x05*$\n\x05Queue\x12\x0b\n\x07\x44\x45\x46\x41ULT\x10\x00\x12\x0e\n\nTASK_QUEUE\x10\x01*S\n\x0bModelStatus\x12\x06\n\x02OK\x10\x00\x12\x0f\n\x0bIN_PROGRESS\x10\x01\x12\x12\n\x0eIN_PROGRESS_OK\x10\x02\x12\n\n\x06\x46\x41ILED\x10\x03\x12\x0b\n\x07UNKNOWN\x10\x04*8\n\x04Role\x12\n\n\x06WORKER\x10\x00\x12\x0c\n\x08\x43OMBINER\x10\x01\x12\x0b\n\x07REDUCER\x10\x02\x12\t\n\x05OTHER\x10\x03*J\n\x07\x43ommand\x12\x08\n\x04IDLE\x10\x00\x12\t\n\x05START\x10\x01\x12\t\n\x05PAUSE\x10\x02\x12\x08\n\x04STOP\x10\x03\x12\t\n\x05RESET\x10\x04\x12\n\n\x06REPORT\x10\x05*I\n\x10\x43onnectionStatus\x12\x11\n\rNOT_ACCEPTING\x10\x00\x12\r\n\tACCEPTING\x10\x01\x12\x13\n\x0fTRY_AGAIN_LATER\x10\x02\x32z\n\x0cModelService\x12\x33\n\x06Upload\x12\x12.fedn.ModelRequest\x1a\x13.fedn.ModelResponse(\x01\x12\x35\n\x08\x44ownload\x12\x12.fedn.ModelRequest\x1a\x13.fedn.ModelResponse0\x01\x32\xbb\x02\n\x07\x43ontrol\x12\x34\n\x05Start\x12\x14.fedn.ControlRequest\x1a\x15.fedn.ControlResponse\x12\x33\n\x04Stop\x12\x14.fedn.ControlRequest\x1a\x15.fedn.ControlResponse\x12\x44\n\x15\x46lushAggregationQueue\x12\x14.fedn.ControlRequest\x1a\x15.fedn.ControlResponse\x12<\n\rSetAggregator\x12\x14.fedn.ControlRequest\x1a\x15.fedn.ControlResponse\x12\x41\n\x12SetServerFunctions\x12\x14.fedn.ControlRequest\x1a\x15.fedn.ControlResponse2V\n\x07Reducer\x12K\n\x0eGetGlobalModel\x12\x1b.fedn.GetGlobalModelRequest\x1a\x1c.fedn.GetGlobalModelResponse2\xab\x03\n\tConnector\x12\x44\n\x14\x41llianceStatusStream\x12\x1c.fedn.ClientAvailableMessage\x1a\x0c.fedn.Status0\x01\x12*\n\nSendStatus\x12\x0c.fedn.Status\x1a\x0e.fedn.Response\x12?\n\x11ListActiveClients\x12\x18.fedn.ListClientsRequest\x1a\x10.fedn.ClientList\x12\x45\n\x10\x41\x63\x63\x65ptingClients\x12\x17.fedn.ConnectionRequest\x1a\x18.fedn.ConnectionResponse\x12\x30\n\rSendHeartbeat\x12\x0f.fedn.Heartbeat\x1a\x0e.fedn.Response\x12\x37\n\x0eReassignClient\x12\x15.fedn.ReassignRequest\x1a\x0e.fedn.Response\x12\x39\n\x0fReconnectClient\x12\x16.fedn.ReconnectRequest\x1a\x0e.fedn.Response2\xfd\x01\n\x08\x43ombiner\x12?\n\nTaskStream\x12\x1c.fedn.ClientAvailableMessage\x1a\x11.fedn.TaskRequest0\x01\x12\x34\n\x0fSendModelUpdate\x12\x11.fedn.ModelUpdate\x1a\x0e.fedn.Response\x12<\n\x13SendModelValidation\x12\x15.fedn.ModelValidation\x1a\x0e.fedn.Response\x12<\n\x13SendModelPrediction\x12\x15.fedn.ModelPrediction\x1a\x0e.fedn.Response2\xec\x03\n\x0f\x46unctionService\x12Z\n\x17HandleProvidedFunctions\x12\x1e.fedn.ProvidedFunctionsRequest\x1a\x1f.fedn.ProvidedFunctionsResponse\x12M\n\x12HandleClientConfig\x12\x19.fedn.ClientConfigRequest\x1a\x1a.fedn.ClientConfigResponse(\x01\x12T\n\x15HandleClientSelection\x12\x1c.fedn.ClientSelectionRequest\x1a\x1d.fedn.ClientSelectionResponse\x12\x43\n\x0eHandleMetadata\x12\x17.fedn.ClientMetaRequest\x1a\x18.fedn.ClientMetaResponse\x12G\n\x10HandleStoreModel\x12\x17.fedn.StoreModelRequest\x1a\x18.fedn.StoreModelResponse(\x01\x12J\n\x11HandleAggregation\x12\x18.fedn.AggregationRequest\x1a\x19.fedn.AggregationResponse0\x01\x62\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x17network/grpc/fedn.proto\x12\x04\x66\x65\x64n\x1a\x1fgoogle/protobuf/timestamp.proto\":\n\x08Response\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x10\n\x08response\x18\x02 \x01(\t\"\xbc\x02\n\x06Status\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x0e\n\x06status\x18\x02 \x01(\t\x12(\n\tlog_level\x18\x03 \x01(\x0e\x32\x15.fedn.Status.LogLevel\x12\x0c\n\x04\x64\x61ta\x18\x04 \x01(\t\x12\x16\n\x0e\x63orrelation_id\x18\x05 \x01(\t\x12-\n\ttimestamp\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x1e\n\x04type\x18\x07 \x01(\x0e\x32\x10.fedn.StatusType\x12\r\n\x05\x65xtra\x18\x08 \x01(\t\x12\x12\n\nsession_id\x18\t \x01(\t\"B\n\x08LogLevel\x12\x08\n\x04INFO\x10\x00\x12\t\n\x05\x44\x45\x42UG\x10\x01\x12\x0b\n\x07WARNING\x10\x02\x12\t\n\x05\x45RROR\x10\x03\x12\t\n\x05\x41UDIT\x10\x04\"\xd8\x01\n\x0bTaskRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x10\n\x08model_id\x18\x03 \x01(\t\x12\x0c\n\x04\x64\x61ta\x18\x04 \x01(\t\x12\x16\n\x0e\x63orrelation_id\x18\x05 \x01(\t\x12\x11\n\ttimestamp\x18\x06 \x01(\t\x12\x0c\n\x04meta\x18\x07 \x01(\t\x12\x12\n\nsession_id\x18\x08 \x01(\t\x12\x1e\n\x04type\x18\t \x01(\x0e\x32\x10.fedn.StatusType\"\xbf\x01\n\x0bModelUpdate\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x10\n\x08model_id\x18\x03 \x01(\t\x12\x17\n\x0fmodel_update_id\x18\x04 \x01(\t\x12\x16\n\x0e\x63orrelation_id\x18\x05 \x01(\t\x12\x11\n\ttimestamp\x18\x06 \x01(\t\x12\x0c\n\x04meta\x18\x07 \x01(\t\x12\x0e\n\x06\x63onfig\x18\x08 \x01(\t\"\xd8\x01\n\x0fModelValidation\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x10\n\x08model_id\x18\x03 \x01(\t\x12\x0c\n\x04\x64\x61ta\x18\x04 \x01(\t\x12\x16\n\x0e\x63orrelation_id\x18\x05 \x01(\t\x12-\n\ttimestamp\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x0c\n\x04meta\x18\x07 \x01(\t\x12\x12\n\nsession_id\x18\x08 \x01(\t\"\xdb\x01\n\x0fModelPrediction\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x10\n\x08model_id\x18\x03 \x01(\t\x12\x0c\n\x04\x64\x61ta\x18\x04 \x01(\t\x12\x16\n\x0e\x63orrelation_id\x18\x05 \x01(\t\x12-\n\ttimestamp\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x0c\n\x04meta\x18\x07 \x01(\t\x12\x15\n\rprediction_id\x18\x08 \x01(\t\"\x89\x01\n\x0cModelRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x0c\n\x04\x64\x61ta\x18\x03 \x01(\x0c\x12\n\n\x02id\x18\x04 \x01(\t\x12!\n\x06status\x18\x05 \x01(\x0e\x32\x11.fedn.ModelStatus\"]\n\rModelResponse\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\x12\n\n\x02id\x18\x02 \x01(\t\x12!\n\x06status\x18\x03 \x01(\x0e\x32\x11.fedn.ModelStatus\x12\x0f\n\x07message\x18\x04 \x01(\t\"U\n\x15GetGlobalModelRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\"h\n\x16GetGlobalModelResponse\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x10\n\x08model_id\x18\x03 \x01(\t\")\n\tHeartbeat\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\"W\n\x16\x43lientAvailableMessage\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\t\x12\x11\n\ttimestamp\x18\x03 \x01(\t\"P\n\x12ListClientsRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1c\n\x07\x63hannel\x18\x02 \x01(\x0e\x32\x0b.fedn.Queue\"*\n\nClientList\x12\x1c\n\x06\x63lient\x18\x01 \x03(\x0b\x32\x0c.fedn.Client\"C\n\x06\x43lient\x12\x18\n\x04role\x18\x01 \x01(\x0e\x32\n.fedn.Role\x12\x0c\n\x04name\x18\x02 \x01(\t\x12\x11\n\tclient_id\x18\x03 \x01(\t\"m\n\x0fReassignRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x0e\n\x06server\x18\x03 \x01(\t\x12\x0c\n\x04port\x18\x04 \x01(\r\"c\n\x10ReconnectRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.fedn.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.fedn.Client\x12\x11\n\treconnect\x18\x03 \x01(\r\"\'\n\tParameter\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t\"T\n\x0e\x43ontrolRequest\x12\x1e\n\x07\x63ommand\x18\x01 \x01(\x0e\x32\r.fedn.Command\x12\"\n\tparameter\x18\x02 \x03(\x0b\x32\x0f.fedn.Parameter\"F\n\x0f\x43ontrolResponse\x12\x0f\n\x07message\x18\x01 \x01(\t\x12\"\n\tparameter\x18\x02 \x03(\x0b\x32\x0f.fedn.Parameter\"\x13\n\x11\x43onnectionRequest\"<\n\x12\x43onnectionResponse\x12&\n\x06status\x18\x01 \x01(\x0e\x32\x16.fedn.ConnectionStatus\"1\n\x18ProvidedFunctionsRequest\x12\x15\n\rfunction_code\x18\x01 \x01(\t\"\xac\x01\n\x19ProvidedFunctionsResponse\x12T\n\x13\x61vailable_functions\x18\x01 \x03(\x0b\x32\x37.fedn.ProvidedFunctionsResponse.AvailableFunctionsEntry\x1a\x39\n\x17\x41vailableFunctionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x08:\x02\x38\x01\"#\n\x13\x43lientConfigRequest\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\"/\n\x14\x43lientConfigResponse\x12\x17\n\x0f\x63lient_settings\x18\x01 \x01(\t\",\n\x16\x43lientSelectionRequest\x12\x12\n\nclient_ids\x18\x01 \x01(\t\"-\n\x17\x43lientSelectionResponse\x12\x12\n\nclient_ids\x18\x01 \x01(\t\"8\n\x11\x43lientMetaRequest\x12\x10\n\x08metadata\x18\x01 \x01(\t\x12\x11\n\tclient_id\x18\x02 \x01(\t\"$\n\x12\x43lientMetaResponse\x12\x0e\n\x06status\x18\x01 \x01(\t\"-\n\x11StoreModelRequest\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\x12\n\n\x02id\x18\x02 \x01(\t\"$\n\x12StoreModelResponse\x12\x0e\n\x06status\x18\x01 \x01(\t\"\'\n\x12\x41ggregationRequest\x12\x11\n\taggregate\x18\x01 \x01(\t\"#\n\x13\x41ggregationResponse\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c*\x8b\x01\n\nStatusType\x12\x07\n\x03LOG\x10\x00\x12\x18\n\x14MODEL_UPDATE_REQUEST\x10\x01\x12\x10\n\x0cMODEL_UPDATE\x10\x02\x12\x1c\n\x18MODEL_VALIDATION_REQUEST\x10\x03\x12\x14\n\x10MODEL_VALIDATION\x10\x04\x12\x14\n\x10MODEL_PREDICTION\x10\x05*$\n\x05Queue\x12\x0b\n\x07\x44\x45\x46\x41ULT\x10\x00\x12\x0e\n\nTASK_QUEUE\x10\x01*S\n\x0bModelStatus\x12\x06\n\x02OK\x10\x00\x12\x0f\n\x0bIN_PROGRESS\x10\x01\x12\x12\n\x0eIN_PROGRESS_OK\x10\x02\x12\n\n\x06\x46\x41ILED\x10\x03\x12\x0b\n\x07UNKNOWN\x10\x04*8\n\x04Role\x12\n\n\x06WORKER\x10\x00\x12\x0c\n\x08\x43OMBINER\x10\x01\x12\x0b\n\x07REDUCER\x10\x02\x12\t\n\x05OTHER\x10\x03*J\n\x07\x43ommand\x12\x08\n\x04IDLE\x10\x00\x12\t\n\x05START\x10\x01\x12\t\n\x05PAUSE\x10\x02\x12\x08\n\x04STOP\x10\x03\x12\t\n\x05RESET\x10\x04\x12\n\n\x06REPORT\x10\x05*I\n\x10\x43onnectionStatus\x12\x11\n\rNOT_ACCEPTING\x10\x00\x12\r\n\tACCEPTING\x10\x01\x12\x13\n\x0fTRY_AGAIN_LATER\x10\x02\x32z\n\x0cModelService\x12\x33\n\x06Upload\x12\x12.fedn.ModelRequest\x1a\x13.fedn.ModelResponse(\x01\x12\x35\n\x08\x44ownload\x12\x12.fedn.ModelRequest\x1a\x13.fedn.ModelResponse0\x01\x32\xbb\x02\n\x07\x43ontrol\x12\x34\n\x05Start\x12\x14.fedn.ControlRequest\x1a\x15.fedn.ControlResponse\x12\x33\n\x04Stop\x12\x14.fedn.ControlRequest\x1a\x15.fedn.ControlResponse\x12\x44\n\x15\x46lushAggregationQueue\x12\x14.fedn.ControlRequest\x1a\x15.fedn.ControlResponse\x12<\n\rSetAggregator\x12\x14.fedn.ControlRequest\x1a\x15.fedn.ControlResponse\x12\x41\n\x12SetServerFunctions\x12\x14.fedn.ControlRequest\x1a\x15.fedn.ControlResponse2V\n\x07Reducer\x12K\n\x0eGetGlobalModel\x12\x1b.fedn.GetGlobalModelRequest\x1a\x1c.fedn.GetGlobalModelResponse2\xab\x03\n\tConnector\x12\x44\n\x14\x41llianceStatusStream\x12\x1c.fedn.ClientAvailableMessage\x1a\x0c.fedn.Status0\x01\x12*\n\nSendStatus\x12\x0c.fedn.Status\x1a\x0e.fedn.Response\x12?\n\x11ListActiveClients\x12\x18.fedn.ListClientsRequest\x1a\x10.fedn.ClientList\x12\x45\n\x10\x41\x63\x63\x65ptingClients\x12\x17.fedn.ConnectionRequest\x1a\x18.fedn.ConnectionResponse\x12\x30\n\rSendHeartbeat\x12\x0f.fedn.Heartbeat\x1a\x0e.fedn.Response\x12\x37\n\x0eReassignClient\x12\x15.fedn.ReassignRequest\x1a\x0e.fedn.Response\x12\x39\n\x0fReconnectClient\x12\x16.fedn.ReconnectRequest\x1a\x0e.fedn.Response2\xfd\x01\n\x08\x43ombiner\x12?\n\nTaskStream\x12\x1c.fedn.ClientAvailableMessage\x1a\x11.fedn.TaskRequest0\x01\x12\x34\n\x0fSendModelUpdate\x12\x11.fedn.ModelUpdate\x1a\x0e.fedn.Response\x12<\n\x13SendModelValidation\x12\x15.fedn.ModelValidation\x1a\x0e.fedn.Response\x12<\n\x13SendModelPrediction\x12\x15.fedn.ModelPrediction\x1a\x0e.fedn.Response2\xec\x03\n\x0f\x46unctionService\x12Z\n\x17HandleProvidedFunctions\x12\x1e.fedn.ProvidedFunctionsRequest\x1a\x1f.fedn.ProvidedFunctionsResponse\x12M\n\x12HandleClientConfig\x12\x19.fedn.ClientConfigRequest\x1a\x1a.fedn.ClientConfigResponse(\x01\x12T\n\x15HandleClientSelection\x12\x1c.fedn.ClientSelectionRequest\x1a\x1d.fedn.ClientSelectionResponse\x12\x43\n\x0eHandleMetadata\x12\x17.fedn.ClientMetaRequest\x1a\x18.fedn.ClientMetaResponse\x12G\n\x10HandleStoreModel\x12\x17.fedn.StoreModelRequest\x1a\x18.fedn.StoreModelResponse(\x01\x12J\n\x11HandleAggregation\x12\x18.fedn.AggregationRequest\x1a\x19.fedn.AggregationResponse0\x01\x62\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'fedn.network.grpc.fedn_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - DESCRIPTOR._options = None - _globals['_PROVIDEDFUNCTIONSRESPONSE_AVAILABLEFUNCTIONSENTRY']._options = None +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'network.grpc.fedn_pb2', _globals) +if not _descriptor._USE_C_DESCRIPTORS: + DESCRIPTOR._loaded_options = None + _globals['_PROVIDEDFUNCTIONSRESPONSE_AVAILABLEFUNCTIONSENTRY']._loaded_options = None _globals['_PROVIDEDFUNCTIONSRESPONSE_AVAILABLEFUNCTIONSENTRY']._serialized_options = b'8\001' - _globals['_STATUSTYPE']._serialized_start=3218 - _globals['_STATUSTYPE']._serialized_end=3357 - _globals['_QUEUE']._serialized_start=3359 - _globals['_QUEUE']._serialized_end=3395 - _globals['_MODELSTATUS']._serialized_start=3397 - _globals['_MODELSTATUS']._serialized_end=3480 - _globals['_ROLE']._serialized_start=3482 - _globals['_ROLE']._serialized_end=3538 - _globals['_COMMAND']._serialized_start=3540 - _globals['_COMMAND']._serialized_end=3614 - _globals['_CONNECTIONSTATUS']._serialized_start=3616 - _globals['_CONNECTIONSTATUS']._serialized_end=3689 - _globals['_RESPONSE']._serialized_start=71 - _globals['_RESPONSE']._serialized_end=129 - _globals['_STATUS']._serialized_start=132 - _globals['_STATUS']._serialized_end=448 - _globals['_STATUS_LOGLEVEL']._serialized_start=382 - _globals['_STATUS_LOGLEVEL']._serialized_end=448 - _globals['_TASKREQUEST']._serialized_start=451 - _globals['_TASKREQUEST']._serialized_end=667 - _globals['_MODELUPDATE']._serialized_start=670 - _globals['_MODELUPDATE']._serialized_end=861 - _globals['_MODELVALIDATION']._serialized_start=864 - _globals['_MODELVALIDATION']._serialized_end=1080 - _globals['_MODELPREDICTION']._serialized_start=1083 - _globals['_MODELPREDICTION']._serialized_end=1302 - _globals['_MODELREQUEST']._serialized_start=1305 - _globals['_MODELREQUEST']._serialized_end=1442 - _globals['_MODELRESPONSE']._serialized_start=1444 - _globals['_MODELRESPONSE']._serialized_end=1537 - _globals['_GETGLOBALMODELREQUEST']._serialized_start=1539 - _globals['_GETGLOBALMODELREQUEST']._serialized_end=1624 - _globals['_GETGLOBALMODELRESPONSE']._serialized_start=1626 - _globals['_GETGLOBALMODELRESPONSE']._serialized_end=1730 - _globals['_HEARTBEAT']._serialized_start=1732 - _globals['_HEARTBEAT']._serialized_end=1773 - _globals['_CLIENTAVAILABLEMESSAGE']._serialized_start=1775 - _globals['_CLIENTAVAILABLEMESSAGE']._serialized_end=1862 - _globals['_LISTCLIENTSREQUEST']._serialized_start=1864 - _globals['_LISTCLIENTSREQUEST']._serialized_end=1944 - _globals['_CLIENTLIST']._serialized_start=1946 - _globals['_CLIENTLIST']._serialized_end=1988 - _globals['_CLIENT']._serialized_start=1990 - _globals['_CLIENT']._serialized_end=2057 - _globals['_REASSIGNREQUEST']._serialized_start=2059 - _globals['_REASSIGNREQUEST']._serialized_end=2168 - _globals['_RECONNECTREQUEST']._serialized_start=2170 - _globals['_RECONNECTREQUEST']._serialized_end=2269 - _globals['_PARAMETER']._serialized_start=2271 - _globals['_PARAMETER']._serialized_end=2310 - _globals['_CONTROLREQUEST']._serialized_start=2312 - _globals['_CONTROLREQUEST']._serialized_end=2396 - _globals['_CONTROLRESPONSE']._serialized_start=2398 - _globals['_CONTROLRESPONSE']._serialized_end=2468 - _globals['_CONNECTIONREQUEST']._serialized_start=2470 - _globals['_CONNECTIONREQUEST']._serialized_end=2489 - _globals['_CONNECTIONRESPONSE']._serialized_start=2491 - _globals['_CONNECTIONRESPONSE']._serialized_end=2551 - _globals['_PROVIDEDFUNCTIONSREQUEST']._serialized_start=2553 - _globals['_PROVIDEDFUNCTIONSREQUEST']._serialized_end=2602 - _globals['_PROVIDEDFUNCTIONSRESPONSE']._serialized_start=2605 - _globals['_PROVIDEDFUNCTIONSRESPONSE']._serialized_end=2777 - _globals['_PROVIDEDFUNCTIONSRESPONSE_AVAILABLEFUNCTIONSENTRY']._serialized_start=2720 - _globals['_PROVIDEDFUNCTIONSRESPONSE_AVAILABLEFUNCTIONSENTRY']._serialized_end=2777 - _globals['_CLIENTCONFIGREQUEST']._serialized_start=2779 - _globals['_CLIENTCONFIGREQUEST']._serialized_end=2814 - _globals['_CLIENTCONFIGRESPONSE']._serialized_start=2816 - _globals['_CLIENTCONFIGRESPONSE']._serialized_end=2863 - _globals['_CLIENTSELECTIONREQUEST']._serialized_start=2865 - _globals['_CLIENTSELECTIONREQUEST']._serialized_end=2909 - _globals['_CLIENTSELECTIONRESPONSE']._serialized_start=2911 - _globals['_CLIENTSELECTIONRESPONSE']._serialized_end=2956 - _globals['_CLIENTMETAREQUEST']._serialized_start=2958 - _globals['_CLIENTMETAREQUEST']._serialized_end=3014 - _globals['_CLIENTMETARESPONSE']._serialized_start=3016 - _globals['_CLIENTMETARESPONSE']._serialized_end=3052 - _globals['_STOREMODELREQUEST']._serialized_start=3054 - _globals['_STOREMODELREQUEST']._serialized_end=3099 - _globals['_STOREMODELRESPONSE']._serialized_start=3101 - _globals['_STOREMODELRESPONSE']._serialized_end=3137 - _globals['_AGGREGATIONREQUEST']._serialized_start=3139 - _globals['_AGGREGATIONREQUEST']._serialized_end=3178 - _globals['_AGGREGATIONRESPONSE']._serialized_start=3180 - _globals['_AGGREGATIONRESPONSE']._serialized_end=3215 - _globals['_MODELSERVICE']._serialized_start=3691 - _globals['_MODELSERVICE']._serialized_end=3813 - _globals['_CONTROL']._serialized_start=3816 - _globals['_CONTROL']._serialized_end=4131 - _globals['_REDUCER']._serialized_start=4133 - _globals['_REDUCER']._serialized_end=4219 - _globals['_CONNECTOR']._serialized_start=4222 - _globals['_CONNECTOR']._serialized_end=4649 - _globals['_COMBINER']._serialized_start=4652 - _globals['_COMBINER']._serialized_end=4905 - _globals['_FUNCTIONSERVICE']._serialized_start=4908 - _globals['_FUNCTIONSERVICE']._serialized_end=5400 + _globals['_STATUSTYPE']._serialized_start=3213 + _globals['_STATUSTYPE']._serialized_end=3352 + _globals['_QUEUE']._serialized_start=3354 + _globals['_QUEUE']._serialized_end=3390 + _globals['_MODELSTATUS']._serialized_start=3392 + _globals['_MODELSTATUS']._serialized_end=3475 + _globals['_ROLE']._serialized_start=3477 + _globals['_ROLE']._serialized_end=3533 + _globals['_COMMAND']._serialized_start=3535 + _globals['_COMMAND']._serialized_end=3609 + _globals['_CONNECTIONSTATUS']._serialized_start=3611 + _globals['_CONNECTIONSTATUS']._serialized_end=3684 + _globals['_RESPONSE']._serialized_start=66 + _globals['_RESPONSE']._serialized_end=124 + _globals['_STATUS']._serialized_start=127 + _globals['_STATUS']._serialized_end=443 + _globals['_STATUS_LOGLEVEL']._serialized_start=377 + _globals['_STATUS_LOGLEVEL']._serialized_end=443 + _globals['_TASKREQUEST']._serialized_start=446 + _globals['_TASKREQUEST']._serialized_end=662 + _globals['_MODELUPDATE']._serialized_start=665 + _globals['_MODELUPDATE']._serialized_end=856 + _globals['_MODELVALIDATION']._serialized_start=859 + _globals['_MODELVALIDATION']._serialized_end=1075 + _globals['_MODELPREDICTION']._serialized_start=1078 + _globals['_MODELPREDICTION']._serialized_end=1297 + _globals['_MODELREQUEST']._serialized_start=1300 + _globals['_MODELREQUEST']._serialized_end=1437 + _globals['_MODELRESPONSE']._serialized_start=1439 + _globals['_MODELRESPONSE']._serialized_end=1532 + _globals['_GETGLOBALMODELREQUEST']._serialized_start=1534 + _globals['_GETGLOBALMODELREQUEST']._serialized_end=1619 + _globals['_GETGLOBALMODELRESPONSE']._serialized_start=1621 + _globals['_GETGLOBALMODELRESPONSE']._serialized_end=1725 + _globals['_HEARTBEAT']._serialized_start=1727 + _globals['_HEARTBEAT']._serialized_end=1768 + _globals['_CLIENTAVAILABLEMESSAGE']._serialized_start=1770 + _globals['_CLIENTAVAILABLEMESSAGE']._serialized_end=1857 + _globals['_LISTCLIENTSREQUEST']._serialized_start=1859 + _globals['_LISTCLIENTSREQUEST']._serialized_end=1939 + _globals['_CLIENTLIST']._serialized_start=1941 + _globals['_CLIENTLIST']._serialized_end=1983 + _globals['_CLIENT']._serialized_start=1985 + _globals['_CLIENT']._serialized_end=2052 + _globals['_REASSIGNREQUEST']._serialized_start=2054 + _globals['_REASSIGNREQUEST']._serialized_end=2163 + _globals['_RECONNECTREQUEST']._serialized_start=2165 + _globals['_RECONNECTREQUEST']._serialized_end=2264 + _globals['_PARAMETER']._serialized_start=2266 + _globals['_PARAMETER']._serialized_end=2305 + _globals['_CONTROLREQUEST']._serialized_start=2307 + _globals['_CONTROLREQUEST']._serialized_end=2391 + _globals['_CONTROLRESPONSE']._serialized_start=2393 + _globals['_CONTROLRESPONSE']._serialized_end=2463 + _globals['_CONNECTIONREQUEST']._serialized_start=2465 + _globals['_CONNECTIONREQUEST']._serialized_end=2484 + _globals['_CONNECTIONRESPONSE']._serialized_start=2486 + _globals['_CONNECTIONRESPONSE']._serialized_end=2546 + _globals['_PROVIDEDFUNCTIONSREQUEST']._serialized_start=2548 + _globals['_PROVIDEDFUNCTIONSREQUEST']._serialized_end=2597 + _globals['_PROVIDEDFUNCTIONSRESPONSE']._serialized_start=2600 + _globals['_PROVIDEDFUNCTIONSRESPONSE']._serialized_end=2772 + _globals['_PROVIDEDFUNCTIONSRESPONSE_AVAILABLEFUNCTIONSENTRY']._serialized_start=2715 + _globals['_PROVIDEDFUNCTIONSRESPONSE_AVAILABLEFUNCTIONSENTRY']._serialized_end=2772 + _globals['_CLIENTCONFIGREQUEST']._serialized_start=2774 + _globals['_CLIENTCONFIGREQUEST']._serialized_end=2809 + _globals['_CLIENTCONFIGRESPONSE']._serialized_start=2811 + _globals['_CLIENTCONFIGRESPONSE']._serialized_end=2858 + _globals['_CLIENTSELECTIONREQUEST']._serialized_start=2860 + _globals['_CLIENTSELECTIONREQUEST']._serialized_end=2904 + _globals['_CLIENTSELECTIONRESPONSE']._serialized_start=2906 + _globals['_CLIENTSELECTIONRESPONSE']._serialized_end=2951 + _globals['_CLIENTMETAREQUEST']._serialized_start=2953 + _globals['_CLIENTMETAREQUEST']._serialized_end=3009 + _globals['_CLIENTMETARESPONSE']._serialized_start=3011 + _globals['_CLIENTMETARESPONSE']._serialized_end=3047 + _globals['_STOREMODELREQUEST']._serialized_start=3049 + _globals['_STOREMODELREQUEST']._serialized_end=3094 + _globals['_STOREMODELRESPONSE']._serialized_start=3096 + _globals['_STOREMODELRESPONSE']._serialized_end=3132 + _globals['_AGGREGATIONREQUEST']._serialized_start=3134 + _globals['_AGGREGATIONREQUEST']._serialized_end=3173 + _globals['_AGGREGATIONRESPONSE']._serialized_start=3175 + _globals['_AGGREGATIONRESPONSE']._serialized_end=3210 + _globals['_MODELSERVICE']._serialized_start=3686 + _globals['_MODELSERVICE']._serialized_end=3808 + _globals['_CONTROL']._serialized_start=3811 + _globals['_CONTROL']._serialized_end=4126 + _globals['_REDUCER']._serialized_start=4128 + _globals['_REDUCER']._serialized_end=4214 + _globals['_CONNECTOR']._serialized_start=4217 + _globals['_CONNECTOR']._serialized_end=4644 + _globals['_COMBINER']._serialized_start=4647 + _globals['_COMBINER']._serialized_end=4900 + _globals['_FUNCTIONSERVICE']._serialized_start=4903 + _globals['_FUNCTIONSERVICE']._serialized_end=5395 # @@protoc_insertion_point(module_scope) diff --git a/fedn/network/grpc/fedn_pb2_grpc.py b/fedn/network/grpc/fedn_pb2_grpc.py index b67e7e095..448a3e02d 100644 --- a/fedn/network/grpc/fedn_pb2_grpc.py +++ b/fedn/network/grpc/fedn_pb2_grpc.py @@ -1,8 +1,28 @@ # 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 fedn.network.grpc import fedn_pb2 as fedn_dot_network_dot_grpc_dot_fedn__pb2 +from fedn.network.grpc import fedn_pb2 as network_dot_grpc_dot_fedn__pb2 + +GRPC_GENERATED_VERSION = '1.66.2' +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 network/grpc/fedn_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): @@ -16,14 +36,14 @@ def __init__(self, channel): """ self.Upload = channel.stream_unary( '/fedn.ModelService/Upload', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.ModelResponse.FromString, + _registered_method=True) self.Download = channel.unary_stream( '/fedn.ModelService/Download', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.ModelResponse.FromString, + _registered_method=True) class ModelServiceServicer(object): @@ -46,18 +66,19 @@ def add_ModelServiceServicer_to_server(servicer, server): rpc_method_handlers = { 'Upload': grpc.stream_unary_rpc_method_handler( servicer.Upload, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ModelRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.ModelResponse.SerializeToString, ), 'Download': grpc.unary_stream_rpc_method_handler( servicer.Download, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ModelRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.ModelResponse.SerializeToString, ), } generic_handler = grpc.method_handlers_generic_handler( 'fedn.ModelService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('fedn.ModelService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -75,11 +96,21 @@ def Upload(request_iterator, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.stream_unary(request_iterator, target, '/fedn.ModelService/Upload', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.stream_unary( + request_iterator, + target, + '/fedn.ModelService/Upload', + network_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.ModelResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Download(request, @@ -92,11 +123,21 @@ def Download(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream(request, target, '/fedn.ModelService/Download', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_stream( + request, + target, + '/fedn.ModelService/Download', + network_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.ModelResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) class ControlStub(object): @@ -110,29 +151,29 @@ def __init__(self, channel): """ self.Start = channel.unary_unary( '/fedn.Control/Start', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, + _registered_method=True) self.Stop = channel.unary_unary( '/fedn.Control/Stop', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, + _registered_method=True) self.FlushAggregationQueue = channel.unary_unary( '/fedn.Control/FlushAggregationQueue', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, + _registered_method=True) self.SetAggregator = channel.unary_unary( '/fedn.Control/SetAggregator', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, + _registered_method=True) self.SetServerFunctions = channel.unary_unary( '/fedn.Control/SetServerFunctions', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, + _registered_method=True) class ControlServicer(object): @@ -173,33 +214,34 @@ def add_ControlServicer_to_server(servicer, server): rpc_method_handlers = { 'Start': grpc.unary_unary_rpc_method_handler( servicer.Start, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ControlRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString, ), 'Stop': grpc.unary_unary_rpc_method_handler( servicer.Stop, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ControlRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString, ), 'FlushAggregationQueue': grpc.unary_unary_rpc_method_handler( servicer.FlushAggregationQueue, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ControlRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString, ), 'SetAggregator': grpc.unary_unary_rpc_method_handler( servicer.SetAggregator, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ControlRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString, ), 'SetServerFunctions': grpc.unary_unary_rpc_method_handler( servicer.SetServerFunctions, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ControlRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString, ), } generic_handler = grpc.method_handlers_generic_handler( 'fedn.Control', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('fedn.Control', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -217,11 +259,21 @@ def Start(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Control/Start', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Control/Start', + network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Stop(request, @@ -234,11 +286,21 @@ def Stop(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Control/Stop', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Control/Stop', + network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def FlushAggregationQueue(request, @@ -251,11 +313,21 @@ def FlushAggregationQueue(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Control/FlushAggregationQueue', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Control/FlushAggregationQueue', + network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def SetAggregator(request, @@ -268,11 +340,21 @@ def SetAggregator(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Control/SetAggregator', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Control/SetAggregator', + network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def SetServerFunctions(request, @@ -285,11 +367,21 @@ def SetServerFunctions(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Control/SetServerFunctions', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Control/SetServerFunctions', + network_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.ControlResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) class ReducerStub(object): @@ -303,9 +395,9 @@ def __init__(self, channel): """ self.GetGlobalModel = channel.unary_unary( '/fedn.Reducer/GetGlobalModel', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.GetGlobalModelRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.GetGlobalModelResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.GetGlobalModelRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.GetGlobalModelResponse.FromString, + _registered_method=True) class ReducerServicer(object): @@ -322,13 +414,14 @@ def add_ReducerServicer_to_server(servicer, server): rpc_method_handlers = { 'GetGlobalModel': grpc.unary_unary_rpc_method_handler( servicer.GetGlobalModel, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.GetGlobalModelRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.GetGlobalModelResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.GetGlobalModelRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.GetGlobalModelResponse.SerializeToString, ), } generic_handler = grpc.method_handlers_generic_handler( 'fedn.Reducer', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('fedn.Reducer', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -346,11 +439,21 @@ def GetGlobalModel(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Reducer/GetGlobalModel', - fedn_dot_network_dot_grpc_dot_fedn__pb2.GetGlobalModelRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.GetGlobalModelResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Reducer/GetGlobalModel', + network_dot_grpc_dot_fedn__pb2.GetGlobalModelRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.GetGlobalModelResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) class ConnectorStub(object): @@ -364,39 +467,39 @@ def __init__(self, channel): """ self.AllianceStatusStream = channel.unary_stream( '/fedn.Connector/AllianceStatusStream', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Status.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.Status.FromString, + _registered_method=True) self.SendStatus = channel.unary_unary( '/fedn.Connector/SendStatus', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Status.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.Status.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.Response.FromString, + _registered_method=True) self.ListActiveClients = channel.unary_unary( '/fedn.Connector/ListActiveClients', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ListClientsRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientList.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ListClientsRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.ClientList.FromString, + _registered_method=True) self.AcceptingClients = channel.unary_unary( '/fedn.Connector/AcceptingClients', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ConnectionRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ConnectionResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ConnectionRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.ConnectionResponse.FromString, + _registered_method=True) self.SendHeartbeat = channel.unary_unary( '/fedn.Connector/SendHeartbeat', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Heartbeat.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.Heartbeat.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.Response.FromString, + _registered_method=True) self.ReassignClient = channel.unary_unary( '/fedn.Connector/ReassignClient', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ReassignRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ReassignRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.Response.FromString, + _registered_method=True) self.ReconnectClient = channel.unary_unary( '/fedn.Connector/ReconnectClient', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ReconnectRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ReconnectRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.Response.FromString, + _registered_method=True) class ConnectorServicer(object): @@ -454,43 +557,44 @@ def add_ConnectorServicer_to_server(servicer, server): rpc_method_handlers = { 'AllianceStatusStream': grpc.unary_stream_rpc_method_handler( servicer.AllianceStatusStream, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Status.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.Status.SerializeToString, ), 'SendStatus': grpc.unary_unary_rpc_method_handler( servicer.SendStatus, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Status.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.Status.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, ), 'ListActiveClients': grpc.unary_unary_rpc_method_handler( servicer.ListActiveClients, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ListClientsRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientList.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ListClientsRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.ClientList.SerializeToString, ), 'AcceptingClients': grpc.unary_unary_rpc_method_handler( servicer.AcceptingClients, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ConnectionRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ConnectionResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ConnectionRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.ConnectionResponse.SerializeToString, ), 'SendHeartbeat': grpc.unary_unary_rpc_method_handler( servicer.SendHeartbeat, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Heartbeat.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.Heartbeat.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, ), 'ReassignClient': grpc.unary_unary_rpc_method_handler( servicer.ReassignClient, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ReassignRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ReassignRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, ), 'ReconnectClient': grpc.unary_unary_rpc_method_handler( servicer.ReconnectClient, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ReconnectRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ReconnectRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, ), } generic_handler = grpc.method_handlers_generic_handler( 'fedn.Connector', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('fedn.Connector', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -508,11 +612,21 @@ def AllianceStatusStream(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream(request, target, '/fedn.Connector/AllianceStatusStream', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.Status.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_stream( + request, + target, + '/fedn.Connector/AllianceStatusStream', + network_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString, + network_dot_grpc_dot_fedn__pb2.Status.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def SendStatus(request, @@ -525,11 +639,21 @@ def SendStatus(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Connector/SendStatus', - fedn_dot_network_dot_grpc_dot_fedn__pb2.Status.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Connector/SendStatus', + network_dot_grpc_dot_fedn__pb2.Status.SerializeToString, + network_dot_grpc_dot_fedn__pb2.Response.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def ListActiveClients(request, @@ -542,11 +666,21 @@ def ListActiveClients(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Connector/ListActiveClients', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ListClientsRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientList.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Connector/ListActiveClients', + network_dot_grpc_dot_fedn__pb2.ListClientsRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.ClientList.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def AcceptingClients(request, @@ -559,11 +693,21 @@ def AcceptingClients(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Connector/AcceptingClients', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ConnectionRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.ConnectionResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Connector/AcceptingClients', + network_dot_grpc_dot_fedn__pb2.ConnectionRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.ConnectionResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def SendHeartbeat(request, @@ -576,11 +720,21 @@ def SendHeartbeat(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Connector/SendHeartbeat', - fedn_dot_network_dot_grpc_dot_fedn__pb2.Heartbeat.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Connector/SendHeartbeat', + network_dot_grpc_dot_fedn__pb2.Heartbeat.SerializeToString, + network_dot_grpc_dot_fedn__pb2.Response.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def ReassignClient(request, @@ -593,11 +747,21 @@ def ReassignClient(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Connector/ReassignClient', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ReassignRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Connector/ReassignClient', + network_dot_grpc_dot_fedn__pb2.ReassignRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.Response.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def ReconnectClient(request, @@ -610,11 +774,21 @@ def ReconnectClient(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Connector/ReconnectClient', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ReconnectRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Connector/ReconnectClient', + network_dot_grpc_dot_fedn__pb2.ReconnectRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.Response.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) class CombinerStub(object): @@ -628,24 +802,24 @@ def __init__(self, channel): """ self.TaskStream = channel.unary_stream( '/fedn.Combiner/TaskStream', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.TaskRequest.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.TaskRequest.FromString, + _registered_method=True) self.SendModelUpdate = channel.unary_unary( '/fedn.Combiner/SendModelUpdate', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelUpdate.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ModelUpdate.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.Response.FromString, + _registered_method=True) self.SendModelValidation = channel.unary_unary( '/fedn.Combiner/SendModelValidation', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelValidation.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ModelValidation.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.Response.FromString, + _registered_method=True) self.SendModelPrediction = channel.unary_unary( '/fedn.Combiner/SendModelPrediction', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelPrediction.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ModelPrediction.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.Response.FromString, + _registered_method=True) class CombinerServicer(object): @@ -681,28 +855,29 @@ def add_CombinerServicer_to_server(servicer, server): rpc_method_handlers = { 'TaskStream': grpc.unary_stream_rpc_method_handler( servicer.TaskStream, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.TaskRequest.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.TaskRequest.SerializeToString, ), 'SendModelUpdate': grpc.unary_unary_rpc_method_handler( servicer.SendModelUpdate, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelUpdate.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ModelUpdate.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, ), 'SendModelValidation': grpc.unary_unary_rpc_method_handler( servicer.SendModelValidation, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelValidation.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ModelValidation.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, ), 'SendModelPrediction': grpc.unary_unary_rpc_method_handler( servicer.SendModelPrediction, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelPrediction.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ModelPrediction.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.Response.SerializeToString, ), } generic_handler = grpc.method_handlers_generic_handler( 'fedn.Combiner', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('fedn.Combiner', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -720,11 +895,21 @@ def TaskStream(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream(request, target, '/fedn.Combiner/TaskStream', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.TaskRequest.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_stream( + request, + target, + '/fedn.Combiner/TaskStream', + network_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString, + network_dot_grpc_dot_fedn__pb2.TaskRequest.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def SendModelUpdate(request, @@ -737,11 +922,21 @@ def SendModelUpdate(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Combiner/SendModelUpdate', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelUpdate.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Combiner/SendModelUpdate', + network_dot_grpc_dot_fedn__pb2.ModelUpdate.SerializeToString, + network_dot_grpc_dot_fedn__pb2.Response.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def SendModelValidation(request, @@ -754,11 +949,21 @@ def SendModelValidation(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Combiner/SendModelValidation', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelValidation.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Combiner/SendModelValidation', + network_dot_grpc_dot_fedn__pb2.ModelValidation.SerializeToString, + network_dot_grpc_dot_fedn__pb2.Response.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def SendModelPrediction(request, @@ -771,11 +976,21 @@ def SendModelPrediction(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.Combiner/SendModelPrediction', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ModelPrediction.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.Response.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.Combiner/SendModelPrediction', + network_dot_grpc_dot_fedn__pb2.ModelPrediction.SerializeToString, + network_dot_grpc_dot_fedn__pb2.Response.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) class FunctionServiceStub(object): @@ -789,34 +1004,34 @@ def __init__(self, channel): """ self.HandleProvidedFunctions = channel.unary_unary( '/fedn.FunctionService/HandleProvidedFunctions', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ProvidedFunctionsRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ProvidedFunctionsResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ProvidedFunctionsRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.ProvidedFunctionsResponse.FromString, + _registered_method=True) self.HandleClientConfig = channel.stream_unary( '/fedn.FunctionService/HandleClientConfig', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientConfigRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientConfigResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ClientConfigRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.ClientConfigResponse.FromString, + _registered_method=True) self.HandleClientSelection = channel.unary_unary( '/fedn.FunctionService/HandleClientSelection', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientSelectionRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientSelectionResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ClientSelectionRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.ClientSelectionResponse.FromString, + _registered_method=True) self.HandleMetadata = channel.unary_unary( '/fedn.FunctionService/HandleMetadata', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientMetaRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientMetaResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.ClientMetaRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.ClientMetaResponse.FromString, + _registered_method=True) self.HandleStoreModel = channel.stream_unary( '/fedn.FunctionService/HandleStoreModel', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.StoreModelRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.StoreModelResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.StoreModelRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.StoreModelResponse.FromString, + _registered_method=True) self.HandleAggregation = channel.unary_stream( '/fedn.FunctionService/HandleAggregation', - request_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.AggregationRequest.SerializeToString, - response_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.AggregationResponse.FromString, - ) + request_serializer=network_dot_grpc_dot_fedn__pb2.AggregationRequest.SerializeToString, + response_deserializer=network_dot_grpc_dot_fedn__pb2.AggregationResponse.FromString, + _registered_method=True) class FunctionServiceServicer(object): @@ -863,38 +1078,39 @@ def add_FunctionServiceServicer_to_server(servicer, server): rpc_method_handlers = { 'HandleProvidedFunctions': grpc.unary_unary_rpc_method_handler( servicer.HandleProvidedFunctions, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ProvidedFunctionsRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ProvidedFunctionsResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ProvidedFunctionsRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.ProvidedFunctionsResponse.SerializeToString, ), 'HandleClientConfig': grpc.stream_unary_rpc_method_handler( servicer.HandleClientConfig, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientConfigRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientConfigResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ClientConfigRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.ClientConfigResponse.SerializeToString, ), 'HandleClientSelection': grpc.unary_unary_rpc_method_handler( servicer.HandleClientSelection, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientSelectionRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientSelectionResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ClientSelectionRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.ClientSelectionResponse.SerializeToString, ), 'HandleMetadata': grpc.unary_unary_rpc_method_handler( servicer.HandleMetadata, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientMetaRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientMetaResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.ClientMetaRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.ClientMetaResponse.SerializeToString, ), 'HandleStoreModel': grpc.stream_unary_rpc_method_handler( servicer.HandleStoreModel, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.StoreModelRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.StoreModelResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.StoreModelRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.StoreModelResponse.SerializeToString, ), 'HandleAggregation': grpc.unary_stream_rpc_method_handler( servicer.HandleAggregation, - request_deserializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.AggregationRequest.FromString, - response_serializer=fedn_dot_network_dot_grpc_dot_fedn__pb2.AggregationResponse.SerializeToString, + request_deserializer=network_dot_grpc_dot_fedn__pb2.AggregationRequest.FromString, + response_serializer=network_dot_grpc_dot_fedn__pb2.AggregationResponse.SerializeToString, ), } generic_handler = grpc.method_handlers_generic_handler( 'fedn.FunctionService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('fedn.FunctionService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -912,11 +1128,21 @@ def HandleProvidedFunctions(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.FunctionService/HandleProvidedFunctions', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ProvidedFunctionsRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.ProvidedFunctionsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.FunctionService/HandleProvidedFunctions', + network_dot_grpc_dot_fedn__pb2.ProvidedFunctionsRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.ProvidedFunctionsResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def HandleClientConfig(request_iterator, @@ -929,11 +1155,21 @@ def HandleClientConfig(request_iterator, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.stream_unary(request_iterator, target, '/fedn.FunctionService/HandleClientConfig', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientConfigRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientConfigResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.stream_unary( + request_iterator, + target, + '/fedn.FunctionService/HandleClientConfig', + network_dot_grpc_dot_fedn__pb2.ClientConfigRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.ClientConfigResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def HandleClientSelection(request, @@ -946,11 +1182,21 @@ def HandleClientSelection(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.FunctionService/HandleClientSelection', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientSelectionRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientSelectionResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.FunctionService/HandleClientSelection', + network_dot_grpc_dot_fedn__pb2.ClientSelectionRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.ClientSelectionResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def HandleMetadata(request, @@ -963,11 +1209,21 @@ def HandleMetadata(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/fedn.FunctionService/HandleMetadata', - fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientMetaRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.ClientMetaResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_unary( + request, + target, + '/fedn.FunctionService/HandleMetadata', + network_dot_grpc_dot_fedn__pb2.ClientMetaRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.ClientMetaResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def HandleStoreModel(request_iterator, @@ -980,11 +1236,21 @@ def HandleStoreModel(request_iterator, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.stream_unary(request_iterator, target, '/fedn.FunctionService/HandleStoreModel', - fedn_dot_network_dot_grpc_dot_fedn__pb2.StoreModelRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.StoreModelResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.stream_unary( + request_iterator, + target, + '/fedn.FunctionService/HandleStoreModel', + network_dot_grpc_dot_fedn__pb2.StoreModelRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.StoreModelResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def HandleAggregation(request, @@ -997,8 +1263,18 @@ def HandleAggregation(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_stream(request, target, '/fedn.FunctionService/HandleAggregation', - fedn_dot_network_dot_grpc_dot_fedn__pb2.AggregationRequest.SerializeToString, - fedn_dot_network_dot_grpc_dot_fedn__pb2.AggregationResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + return grpc.experimental.unary_stream( + request, + target, + '/fedn.FunctionService/HandleAggregation', + network_dot_grpc_dot_fedn__pb2.AggregationRequest.SerializeToString, + network_dot_grpc_dot_fedn__pb2.AggregationResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True)