diff --git a/.github/workflows/code-checks.yaml b/.github/workflows/code-checks.yaml
index c1ec38548..c76c418f9 100644
--- a/.github/workflows/code-checks.yaml
+++ b/.github/workflows/code-checks.yaml
@@ -18,6 +18,8 @@ jobs:
--skip .venv
--skip .mnist-keras
--skip .mnist-pytorch
+ --skip fedn_pb2.py
+ --skip fedn_pb2_grpc.py
- name: check Python formatting
run: >
@@ -25,12 +27,14 @@ jobs:
--exclude .venv
--exclude .mnist-keras
--exclude .mnist-pytorch
+ --exclude fedn_pb2.py
+ --exclude fedn_pb2_grpc.py
.
- name: run Python linter
run: >
.venv/bin/flake8 .
- --exclude ".venv,.mnist-keras,.mnist-pytorch,fedn_pb2.py"
+ --exclude ".venv,.mnist-keras,.mnist-pytorch,fedn_pb2.py,fedn_pb2_grpc.py"
- name: check for floating imports
run: >
diff --git a/README.rst b/README.rst
index 42503985a..2afb60ebc 100644
--- a/README.rst
+++ b/README.rst
@@ -101,7 +101,7 @@ To connect a client that uses the data partition 'data/clients/1/mnist.pt':
-v $PWD/data/clients/1:/var/data \
-e ENTRYPOINT_OPTS=--data_path=/var/data/mnist.pt \
--network=fedn_default \
- ghcr.io/scaleoutsystems/fedn/fedn:develop-mnist-pytorch run client -in client.yaml --name client1
+ ghcr.io/scaleoutsystems/fedn/fedn:master-mnist-pytorch run client -in client.yaml --name client1
You are now ready to start training the model at http://localhost:8090/control.
diff --git a/fedn/fedn/common/net/grpc/fedn.proto b/fedn/fedn/common/net/grpc/fedn.proto
index dca66fe20..ff0ee293c 100644
--- a/fedn/fedn/common/net/grpc/fedn.proto
+++ b/fedn/fedn/common/net/grpc/fedn.proto
@@ -4,7 +4,6 @@ package grpc;
message Response {
Client sender = 1;
- //string client = 1;
string response = 2;
}
@@ -19,7 +18,6 @@ enum StatusType {
message Status {
Client sender = 1;
- //string client = 1;
string status = 2;
enum LogLevel {
@@ -95,6 +93,7 @@ enum ModelStatus {
IN_PROGRESS_OK = 2;
FAILED = 3;
}
+
message ModelRequest {
Client sender = 1;
Client receiver = 2;
@@ -204,7 +203,8 @@ message ReportResponse {
service Control {
rpc Start(ControlRequest) returns (ControlResponse);
rpc Stop(ControlRequest) returns (ControlResponse);
- rpc Configure(ControlRequest) returns (ReportResponse);
+ rpc Configure(ControlRequest) returns (ReportResponse);
+ rpc FlushAggregationQueue(ControlRequest) returns (ControlResponse);
rpc Report(ControlRequest) returns (ReportResponse);
}
diff --git a/fedn/fedn/common/net/grpc/fedn_pb2.py b/fedn/fedn/common/net/grpc/fedn_pb2.py
index 19cd119c6..fa4fbb16d 100644
--- a/fedn/fedn/common/net/grpc/fedn_pb2.py
+++ b/fedn/fedn/common/net/grpc/fedn_pb2.py
@@ -2,19 +2,20 @@
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: fedn/common/net/grpc/fedn.proto
"""Generated protocol buffer code."""
+from google.protobuf.internal import enum_type_wrapper
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import message as _message
from google.protobuf import reflection as _reflection
from google.protobuf import symbol_database as _symbol_database
-from google.protobuf.internal import enum_type_wrapper
-
# @@protoc_insertion_point(imports)
_sym_db = _symbol_database.Default()
-DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1f\x66\x65\x64n/common/net/grpc/fedn.proto\x12\x04grpc\":\n\x08Response\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x10\n\x08response\x18\x02 \x01(\t\"\x8c\x02\n\x06Status\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x0e\n\x06status\x18\x02 \x01(\t\x12(\n\tlog_level\x18\x03 \x01(\x0e\x32\x15.grpc.Status.LogLevel\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\x1e\n\x04type\x18\x07 \x01(\x0e\x32\x10.grpc.StatusType\x12\r\n\x05\x65xtra\x18\x08 \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\"\xab\x01\n\x12ModelUpdateRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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\"\xaf\x01\n\x0bModelUpdate\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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\"\xc5\x01\n\x16ModelValidationRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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\x14\n\x0cis_inference\x18\x08 \x01(\x08\"\xa8\x01\n\x0fModelValidation\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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\"\x89\x01\n\x0cModelRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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.grpc.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.grpc.ModelStatus\x12\x0f\n\x07message\x18\x04 \x01(\t\"U\n\x15GetGlobalModelRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.Client\"h\n\x16GetGlobalModelResponse\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.Client\x12\x10\n\x08model_id\x18\x03 \x01(\t\")\n\tHeartbeat\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\"W\n\x16\x43lientAvailableMessage\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\t\x12\x11\n\ttimestamp\x18\x03 \x01(\t\"R\n\x12ListClientsRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x07\x63hannel\x18\x02 \x01(\x0e\x32\r.grpc.Channel\"*\n\nClientList\x12\x1c\n\x06\x63lient\x18\x01 \x03(\x0b\x32\x0c.grpc.Client\"0\n\x06\x43lient\x12\x18\n\x04role\x18\x01 \x01(\x0e\x32\n.grpc.Role\x12\x0c\n\x04name\x18\x02 \x01(\t\"m\n\x0fReassignRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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.grpc.Command\x12\"\n\tparameter\x18\x02 \x03(\x0b\x32\x0f.grpc.Parameter\"F\n\x0f\x43ontrolResponse\x12\x0f\n\x07message\x18\x01 \x01(\t\x12\"\n\tparameter\x18\x02 \x03(\x0b\x32\x0f.grpc.Parameter\"R\n\x0eReportResponse\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\"\n\tparameter\x18\x02 \x03(\x0b\x32\x0f.grpc.Parameter\"\x13\n\x11\x43onnectionRequest\"<\n\x12\x43onnectionResponse\x12&\n\x06status\x18\x01 \x01(\x0e\x32\x16.grpc.ConnectionStatus*\x84\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\r\n\tINFERENCE\x10\x05*\x86\x01\n\x07\x43hannel\x12\x0b\n\x07\x44\x45\x46\x41ULT\x10\x00\x12\x19\n\x15MODEL_UPDATE_REQUESTS\x10\x01\x12\x11\n\rMODEL_UPDATES\x10\x02\x12\x1d\n\x19MODEL_VALIDATION_REQUESTS\x10\x03\x12\x15\n\x11MODEL_VALIDATIONS\x10\x04\x12\n\n\x06STATUS\x10\x05*F\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*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.grpc.ModelRequest\x1a\x13.grpc.ModelResponse(\x01\x12\x35\n\x08\x44ownload\x12\x12.grpc.ModelRequest\x1a\x13.grpc.ModelResponse0\x01\x32\xe3\x01\n\x07\x43ontrol\x12\x34\n\x05Start\x12\x14.grpc.ControlRequest\x1a\x15.grpc.ControlResponse\x12\x33\n\x04Stop\x12\x14.grpc.ControlRequest\x1a\x15.grpc.ControlResponse\x12\x37\n\tConfigure\x12\x14.grpc.ControlRequest\x1a\x14.grpc.ReportResponse\x12\x34\n\x06Report\x12\x14.grpc.ControlRequest\x1a\x14.grpc.ReportResponse2V\n\x07Reducer\x12K\n\x0eGetGlobalModel\x12\x1b.grpc.GetGlobalModelRequest\x1a\x1c.grpc.GetGlobalModelResponse2\xab\x03\n\tConnector\x12\x44\n\x14\x41llianceStatusStream\x12\x1c.grpc.ClientAvailableMessage\x1a\x0c.grpc.Status0\x01\x12*\n\nSendStatus\x12\x0c.grpc.Status\x1a\x0e.grpc.Response\x12?\n\x11ListActiveClients\x12\x18.grpc.ListClientsRequest\x1a\x10.grpc.ClientList\x12\x45\n\x10\x41\x63\x63\x65ptingClients\x12\x17.grpc.ConnectionRequest\x1a\x18.grpc.ConnectionResponse\x12\x30\n\rSendHeartbeat\x12\x0f.grpc.Heartbeat\x1a\x0e.grpc.Response\x12\x37\n\x0eReassignClient\x12\x15.grpc.ReassignRequest\x1a\x0e.grpc.Response\x12\x39\n\x0fReconnectClient\x12\x16.grpc.ReconnectRequest\x1a\x0e.grpc.Response2\xda\x04\n\x08\x43ombiner\x12T\n\x18ModelUpdateRequestStream\x12\x1c.grpc.ClientAvailableMessage\x1a\x18.grpc.ModelUpdateRequest0\x01\x12\x46\n\x11ModelUpdateStream\x12\x1c.grpc.ClientAvailableMessage\x1a\x11.grpc.ModelUpdate0\x01\x12\\\n\x1cModelValidationRequestStream\x12\x1c.grpc.ClientAvailableMessage\x1a\x1c.grpc.ModelValidationRequest0\x01\x12N\n\x15ModelValidationStream\x12\x1c.grpc.ClientAvailableMessage\x1a\x15.grpc.ModelValidation0\x01\x12\x42\n\x16SendModelUpdateRequest\x12\x18.grpc.ModelUpdateRequest\x1a\x0e.grpc.Response\x12\x34\n\x0fSendModelUpdate\x12\x11.grpc.ModelUpdate\x1a\x0e.grpc.Response\x12J\n\x1aSendModelValidationRequest\x12\x1c.grpc.ModelValidationRequest\x1a\x0e.grpc.Response\x12<\n\x13SendModelValidation\x12\x15.grpc.ModelValidation\x1a\x0e.grpc.Responseb\x06proto3') # noqa: E501
+
+
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1f\x66\x65\x64n/common/net/grpc/fedn.proto\x12\x04grpc\":\n\x08Response\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x10\n\x08response\x18\x02 \x01(\t\"\x8c\x02\n\x06Status\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x0e\n\x06status\x18\x02 \x01(\t\x12(\n\tlog_level\x18\x03 \x01(\x0e\x32\x15.grpc.Status.LogLevel\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\x1e\n\x04type\x18\x07 \x01(\x0e\x32\x10.grpc.StatusType\x12\r\n\x05\x65xtra\x18\x08 \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\"\xab\x01\n\x12ModelUpdateRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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\"\xaf\x01\n\x0bModelUpdate\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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\"\xc5\x01\n\x16ModelValidationRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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\x14\n\x0cis_inference\x18\x08 \x01(\x08\"\xa8\x01\n\x0fModelValidation\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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\"\x89\x01\n\x0cModelRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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.grpc.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.grpc.ModelStatus\x12\x0f\n\x07message\x18\x04 \x01(\t\"U\n\x15GetGlobalModelRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.Client\"h\n\x16GetGlobalModelResponse\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.Client\x12\x10\n\x08model_id\x18\x03 \x01(\t\")\n\tHeartbeat\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\"W\n\x16\x43lientAvailableMessage\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\t\x12\x11\n\ttimestamp\x18\x03 \x01(\t\"R\n\x12ListClientsRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x07\x63hannel\x18\x02 \x01(\x0e\x32\r.grpc.Channel\"*\n\nClientList\x12\x1c\n\x06\x63lient\x18\x01 \x03(\x0b\x32\x0c.grpc.Client\"0\n\x06\x43lient\x12\x18\n\x04role\x18\x01 \x01(\x0e\x32\n.grpc.Role\x12\x0c\n\x04name\x18\x02 \x01(\t\"m\n\x0fReassignRequest\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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.grpc.Client\x12\x1e\n\x08receiver\x18\x02 \x01(\x0b\x32\x0c.grpc.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.grpc.Command\x12\"\n\tparameter\x18\x02 \x03(\x0b\x32\x0f.grpc.Parameter\"F\n\x0f\x43ontrolResponse\x12\x0f\n\x07message\x18\x01 \x01(\t\x12\"\n\tparameter\x18\x02 \x03(\x0b\x32\x0f.grpc.Parameter\"R\n\x0eReportResponse\x12\x1c\n\x06sender\x18\x01 \x01(\x0b\x32\x0c.grpc.Client\x12\"\n\tparameter\x18\x02 \x03(\x0b\x32\x0f.grpc.Parameter\"\x13\n\x11\x43onnectionRequest\"<\n\x12\x43onnectionResponse\x12&\n\x06status\x18\x01 \x01(\x0e\x32\x16.grpc.ConnectionStatus*\x84\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\r\n\tINFERENCE\x10\x05*\x86\x01\n\x07\x43hannel\x12\x0b\n\x07\x44\x45\x46\x41ULT\x10\x00\x12\x19\n\x15MODEL_UPDATE_REQUESTS\x10\x01\x12\x11\n\rMODEL_UPDATES\x10\x02\x12\x1d\n\x19MODEL_VALIDATION_REQUESTS\x10\x03\x12\x15\n\x11MODEL_VALIDATIONS\x10\x04\x12\n\n\x06STATUS\x10\x05*F\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*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.grpc.ModelRequest\x1a\x13.grpc.ModelResponse(\x01\x12\x35\n\x08\x44ownload\x12\x12.grpc.ModelRequest\x1a\x13.grpc.ModelResponse0\x01\x32\xa9\x02\n\x07\x43ontrol\x12\x34\n\x05Start\x12\x14.grpc.ControlRequest\x1a\x15.grpc.ControlResponse\x12\x33\n\x04Stop\x12\x14.grpc.ControlRequest\x1a\x15.grpc.ControlResponse\x12\x37\n\tConfigure\x12\x14.grpc.ControlRequest\x1a\x14.grpc.ReportResponse\x12\x44\n\x15\x46lushAggregationQueue\x12\x14.grpc.ControlRequest\x1a\x15.grpc.ControlResponse\x12\x34\n\x06Report\x12\x14.grpc.ControlRequest\x1a\x14.grpc.ReportResponse2V\n\x07Reducer\x12K\n\x0eGetGlobalModel\x12\x1b.grpc.GetGlobalModelRequest\x1a\x1c.grpc.GetGlobalModelResponse2\xab\x03\n\tConnector\x12\x44\n\x14\x41llianceStatusStream\x12\x1c.grpc.ClientAvailableMessage\x1a\x0c.grpc.Status0\x01\x12*\n\nSendStatus\x12\x0c.grpc.Status\x1a\x0e.grpc.Response\x12?\n\x11ListActiveClients\x12\x18.grpc.ListClientsRequest\x1a\x10.grpc.ClientList\x12\x45\n\x10\x41\x63\x63\x65ptingClients\x12\x17.grpc.ConnectionRequest\x1a\x18.grpc.ConnectionResponse\x12\x30\n\rSendHeartbeat\x12\x0f.grpc.Heartbeat\x1a\x0e.grpc.Response\x12\x37\n\x0eReassignClient\x12\x15.grpc.ReassignRequest\x1a\x0e.grpc.Response\x12\x39\n\x0fReconnectClient\x12\x16.grpc.ReconnectRequest\x1a\x0e.grpc.Response2\xda\x04\n\x08\x43ombiner\x12T\n\x18ModelUpdateRequestStream\x12\x1c.grpc.ClientAvailableMessage\x1a\x18.grpc.ModelUpdateRequest0\x01\x12\x46\n\x11ModelUpdateStream\x12\x1c.grpc.ClientAvailableMessage\x1a\x11.grpc.ModelUpdate0\x01\x12\\\n\x1cModelValidationRequestStream\x12\x1c.grpc.ClientAvailableMessage\x1a\x1c.grpc.ModelValidationRequest0\x01\x12N\n\x15ModelValidationStream\x12\x1c.grpc.ClientAvailableMessage\x1a\x15.grpc.ModelValidation0\x01\x12\x42\n\x16SendModelUpdateRequest\x12\x18.grpc.ModelUpdateRequest\x1a\x0e.grpc.Response\x12\x34\n\x0fSendModelUpdate\x12\x11.grpc.ModelUpdate\x1a\x0e.grpc.Response\x12J\n\x1aSendModelValidationRequest\x12\x1c.grpc.ModelValidationRequest\x1a\x0e.grpc.Response\x12<\n\x13SendModelValidation\x12\x15.grpc.ModelValidation\x1a\x0e.grpc.Responseb\x06proto3')
_STATUSTYPE = DESCRIPTOR.enum_types_by_name['StatusType']
StatusType = enum_type_wrapper.EnumTypeWrapper(_STATUSTYPE)
@@ -84,164 +85,164 @@
_CONNECTIONRESPONSE = DESCRIPTOR.message_types_by_name['ConnectionResponse']
_STATUS_LOGLEVEL = _STATUS.enum_types_by_name['LogLevel']
Response = _reflection.GeneratedProtocolMessageType('Response', (_message.Message,), {
- 'DESCRIPTOR': _RESPONSE,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.Response)
-})
+ 'DESCRIPTOR' : _RESPONSE,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.Response)
+ })
_sym_db.RegisterMessage(Response)
Status = _reflection.GeneratedProtocolMessageType('Status', (_message.Message,), {
- 'DESCRIPTOR': _STATUS,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.Status)
-})
+ 'DESCRIPTOR' : _STATUS,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.Status)
+ })
_sym_db.RegisterMessage(Status)
ModelUpdateRequest = _reflection.GeneratedProtocolMessageType('ModelUpdateRequest', (_message.Message,), {
- 'DESCRIPTOR': _MODELUPDATEREQUEST,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ModelUpdateRequest)
-})
+ 'DESCRIPTOR' : _MODELUPDATEREQUEST,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ModelUpdateRequest)
+ })
_sym_db.RegisterMessage(ModelUpdateRequest)
ModelUpdate = _reflection.GeneratedProtocolMessageType('ModelUpdate', (_message.Message,), {
- 'DESCRIPTOR': _MODELUPDATE,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ModelUpdate)
-})
+ 'DESCRIPTOR' : _MODELUPDATE,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ModelUpdate)
+ })
_sym_db.RegisterMessage(ModelUpdate)
ModelValidationRequest = _reflection.GeneratedProtocolMessageType('ModelValidationRequest', (_message.Message,), {
- 'DESCRIPTOR': _MODELVALIDATIONREQUEST,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ModelValidationRequest)
-})
+ 'DESCRIPTOR' : _MODELVALIDATIONREQUEST,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ModelValidationRequest)
+ })
_sym_db.RegisterMessage(ModelValidationRequest)
ModelValidation = _reflection.GeneratedProtocolMessageType('ModelValidation', (_message.Message,), {
- 'DESCRIPTOR': _MODELVALIDATION,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ModelValidation)
-})
+ 'DESCRIPTOR' : _MODELVALIDATION,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ModelValidation)
+ })
_sym_db.RegisterMessage(ModelValidation)
ModelRequest = _reflection.GeneratedProtocolMessageType('ModelRequest', (_message.Message,), {
- 'DESCRIPTOR': _MODELREQUEST,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ModelRequest)
-})
+ 'DESCRIPTOR' : _MODELREQUEST,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ModelRequest)
+ })
_sym_db.RegisterMessage(ModelRequest)
ModelResponse = _reflection.GeneratedProtocolMessageType('ModelResponse', (_message.Message,), {
- 'DESCRIPTOR': _MODELRESPONSE,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ModelResponse)
-})
+ 'DESCRIPTOR' : _MODELRESPONSE,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ModelResponse)
+ })
_sym_db.RegisterMessage(ModelResponse)
GetGlobalModelRequest = _reflection.GeneratedProtocolMessageType('GetGlobalModelRequest', (_message.Message,), {
- 'DESCRIPTOR': _GETGLOBALMODELREQUEST,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.GetGlobalModelRequest)
-})
+ 'DESCRIPTOR' : _GETGLOBALMODELREQUEST,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.GetGlobalModelRequest)
+ })
_sym_db.RegisterMessage(GetGlobalModelRequest)
GetGlobalModelResponse = _reflection.GeneratedProtocolMessageType('GetGlobalModelResponse', (_message.Message,), {
- 'DESCRIPTOR': _GETGLOBALMODELRESPONSE,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.GetGlobalModelResponse)
-})
+ 'DESCRIPTOR' : _GETGLOBALMODELRESPONSE,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.GetGlobalModelResponse)
+ })
_sym_db.RegisterMessage(GetGlobalModelResponse)
Heartbeat = _reflection.GeneratedProtocolMessageType('Heartbeat', (_message.Message,), {
- 'DESCRIPTOR': _HEARTBEAT,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.Heartbeat)
-})
+ 'DESCRIPTOR' : _HEARTBEAT,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.Heartbeat)
+ })
_sym_db.RegisterMessage(Heartbeat)
ClientAvailableMessage = _reflection.GeneratedProtocolMessageType('ClientAvailableMessage', (_message.Message,), {
- 'DESCRIPTOR': _CLIENTAVAILABLEMESSAGE,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ClientAvailableMessage)
-})
+ 'DESCRIPTOR' : _CLIENTAVAILABLEMESSAGE,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ClientAvailableMessage)
+ })
_sym_db.RegisterMessage(ClientAvailableMessage)
ListClientsRequest = _reflection.GeneratedProtocolMessageType('ListClientsRequest', (_message.Message,), {
- 'DESCRIPTOR': _LISTCLIENTSREQUEST,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ListClientsRequest)
-})
+ 'DESCRIPTOR' : _LISTCLIENTSREQUEST,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ListClientsRequest)
+ })
_sym_db.RegisterMessage(ListClientsRequest)
ClientList = _reflection.GeneratedProtocolMessageType('ClientList', (_message.Message,), {
- 'DESCRIPTOR': _CLIENTLIST,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ClientList)
-})
+ 'DESCRIPTOR' : _CLIENTLIST,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ClientList)
+ })
_sym_db.RegisterMessage(ClientList)
Client = _reflection.GeneratedProtocolMessageType('Client', (_message.Message,), {
- 'DESCRIPTOR': _CLIENT,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.Client)
-})
+ 'DESCRIPTOR' : _CLIENT,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.Client)
+ })
_sym_db.RegisterMessage(Client)
ReassignRequest = _reflection.GeneratedProtocolMessageType('ReassignRequest', (_message.Message,), {
- 'DESCRIPTOR': _REASSIGNREQUEST,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ReassignRequest)
-})
+ 'DESCRIPTOR' : _REASSIGNREQUEST,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ReassignRequest)
+ })
_sym_db.RegisterMessage(ReassignRequest)
ReconnectRequest = _reflection.GeneratedProtocolMessageType('ReconnectRequest', (_message.Message,), {
- 'DESCRIPTOR': _RECONNECTREQUEST,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ReconnectRequest)
-})
+ 'DESCRIPTOR' : _RECONNECTREQUEST,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ReconnectRequest)
+ })
_sym_db.RegisterMessage(ReconnectRequest)
Parameter = _reflection.GeneratedProtocolMessageType('Parameter', (_message.Message,), {
- 'DESCRIPTOR': _PARAMETER,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.Parameter)
-})
+ 'DESCRIPTOR' : _PARAMETER,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.Parameter)
+ })
_sym_db.RegisterMessage(Parameter)
ControlRequest = _reflection.GeneratedProtocolMessageType('ControlRequest', (_message.Message,), {
- 'DESCRIPTOR': _CONTROLREQUEST,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ControlRequest)
-})
+ 'DESCRIPTOR' : _CONTROLREQUEST,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ControlRequest)
+ })
_sym_db.RegisterMessage(ControlRequest)
ControlResponse = _reflection.GeneratedProtocolMessageType('ControlResponse', (_message.Message,), {
- 'DESCRIPTOR': _CONTROLRESPONSE,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ControlResponse)
-})
+ 'DESCRIPTOR' : _CONTROLRESPONSE,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ControlResponse)
+ })
_sym_db.RegisterMessage(ControlResponse)
ReportResponse = _reflection.GeneratedProtocolMessageType('ReportResponse', (_message.Message,), {
- 'DESCRIPTOR': _REPORTRESPONSE,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ReportResponse)
-})
+ 'DESCRIPTOR' : _REPORTRESPONSE,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ReportResponse)
+ })
_sym_db.RegisterMessage(ReportResponse)
ConnectionRequest = _reflection.GeneratedProtocolMessageType('ConnectionRequest', (_message.Message,), {
- 'DESCRIPTOR': _CONNECTIONREQUEST,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ConnectionRequest)
-})
+ 'DESCRIPTOR' : _CONNECTIONREQUEST,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ConnectionRequest)
+ })
_sym_db.RegisterMessage(ConnectionRequest)
ConnectionResponse = _reflection.GeneratedProtocolMessageType('ConnectionResponse', (_message.Message,), {
- 'DESCRIPTOR': _CONNECTIONRESPONSE,
- '__module__': 'fedn.common.net.grpc.fedn_pb2'
- # @@protoc_insertion_point(class_scope:grpc.ConnectionResponse)
-})
+ 'DESCRIPTOR' : _CONNECTIONRESPONSE,
+ '__module__' : 'fedn.common.net.grpc.fedn_pb2'
+ # @@protoc_insertion_point(class_scope:grpc.ConnectionResponse)
+ })
_sym_db.RegisterMessage(ConnectionResponse)
_MODELSERVICE = DESCRIPTOR.services_by_name['ModelService']
@@ -249,77 +250,77 @@
_REDUCER = DESCRIPTOR.services_by_name['Reducer']
_CONNECTOR = DESCRIPTOR.services_by_name['Connector']
_COMBINER = DESCRIPTOR.services_by_name['Combiner']
-if _descriptor._USE_C_DESCRIPTORS is False:
-
- DESCRIPTOR._options = None
- _STATUSTYPE._serialized_start = 2412
- _STATUSTYPE._serialized_end = 2544
- _CHANNEL._serialized_start = 2547
- _CHANNEL._serialized_end = 2681
- _MODELSTATUS._serialized_start = 2683
- _MODELSTATUS._serialized_end = 2753
- _ROLE._serialized_start = 2755
- _ROLE._serialized_end = 2811
- _COMMAND._serialized_start = 2813
- _COMMAND._serialized_end = 2887
- _CONNECTIONSTATUS._serialized_start = 2889
- _CONNECTIONSTATUS._serialized_end = 2962
- _RESPONSE._serialized_start = 41
- _RESPONSE._serialized_end = 99
- _STATUS._serialized_start = 102
- _STATUS._serialized_end = 370
- _STATUS_LOGLEVEL._serialized_start = 304
- _STATUS_LOGLEVEL._serialized_end = 370
- _MODELUPDATEREQUEST._serialized_start = 373
- _MODELUPDATEREQUEST._serialized_end = 544
- _MODELUPDATE._serialized_start = 547
- _MODELUPDATE._serialized_end = 722
- _MODELVALIDATIONREQUEST._serialized_start = 725
- _MODELVALIDATIONREQUEST._serialized_end = 922
- _MODELVALIDATION._serialized_start = 925
- _MODELVALIDATION._serialized_end = 1093
- _MODELREQUEST._serialized_start = 1096
- _MODELREQUEST._serialized_end = 1233
- _MODELRESPONSE._serialized_start = 1235
- _MODELRESPONSE._serialized_end = 1328
- _GETGLOBALMODELREQUEST._serialized_start = 1330
- _GETGLOBALMODELREQUEST._serialized_end = 1415
- _GETGLOBALMODELRESPONSE._serialized_start = 1417
- _GETGLOBALMODELRESPONSE._serialized_end = 1521
- _HEARTBEAT._serialized_start = 1523
- _HEARTBEAT._serialized_end = 1564
- _CLIENTAVAILABLEMESSAGE._serialized_start = 1566
- _CLIENTAVAILABLEMESSAGE._serialized_end = 1653
- _LISTCLIENTSREQUEST._serialized_start = 1655
- _LISTCLIENTSREQUEST._serialized_end = 1737
- _CLIENTLIST._serialized_start = 1739
- _CLIENTLIST._serialized_end = 1781
- _CLIENT._serialized_start = 1783
- _CLIENT._serialized_end = 1831
- _REASSIGNREQUEST._serialized_start = 1833
- _REASSIGNREQUEST._serialized_end = 1942
- _RECONNECTREQUEST._serialized_start = 1944
- _RECONNECTREQUEST._serialized_end = 2043
- _PARAMETER._serialized_start = 2045
- _PARAMETER._serialized_end = 2084
- _CONTROLREQUEST._serialized_start = 2086
- _CONTROLREQUEST._serialized_end = 2170
- _CONTROLRESPONSE._serialized_start = 2172
- _CONTROLRESPONSE._serialized_end = 2242
- _REPORTRESPONSE._serialized_start = 2244
- _REPORTRESPONSE._serialized_end = 2326
- _CONNECTIONREQUEST._serialized_start = 2328
- _CONNECTIONREQUEST._serialized_end = 2347
- _CONNECTIONRESPONSE._serialized_start = 2349
- _CONNECTIONRESPONSE._serialized_end = 2409
- _MODELSERVICE._serialized_start = 2964
- _MODELSERVICE._serialized_end = 3086
- _CONTROL._serialized_start = 3089
- _CONTROL._serialized_end = 3316
- _REDUCER._serialized_start = 3318
- _REDUCER._serialized_end = 3404
- _CONNECTOR._serialized_start = 3407
- _CONNECTOR._serialized_end = 3834
- _COMBINER._serialized_start = 3837
- _COMBINER._serialized_end = 4439
+if _descriptor._USE_C_DESCRIPTORS == False:
+
+ DESCRIPTOR._options = None
+ _STATUSTYPE._serialized_start=2412
+ _STATUSTYPE._serialized_end=2544
+ _CHANNEL._serialized_start=2547
+ _CHANNEL._serialized_end=2681
+ _MODELSTATUS._serialized_start=2683
+ _MODELSTATUS._serialized_end=2753
+ _ROLE._serialized_start=2755
+ _ROLE._serialized_end=2811
+ _COMMAND._serialized_start=2813
+ _COMMAND._serialized_end=2887
+ _CONNECTIONSTATUS._serialized_start=2889
+ _CONNECTIONSTATUS._serialized_end=2962
+ _RESPONSE._serialized_start=41
+ _RESPONSE._serialized_end=99
+ _STATUS._serialized_start=102
+ _STATUS._serialized_end=370
+ _STATUS_LOGLEVEL._serialized_start=304
+ _STATUS_LOGLEVEL._serialized_end=370
+ _MODELUPDATEREQUEST._serialized_start=373
+ _MODELUPDATEREQUEST._serialized_end=544
+ _MODELUPDATE._serialized_start=547
+ _MODELUPDATE._serialized_end=722
+ _MODELVALIDATIONREQUEST._serialized_start=725
+ _MODELVALIDATIONREQUEST._serialized_end=922
+ _MODELVALIDATION._serialized_start=925
+ _MODELVALIDATION._serialized_end=1093
+ _MODELREQUEST._serialized_start=1096
+ _MODELREQUEST._serialized_end=1233
+ _MODELRESPONSE._serialized_start=1235
+ _MODELRESPONSE._serialized_end=1328
+ _GETGLOBALMODELREQUEST._serialized_start=1330
+ _GETGLOBALMODELREQUEST._serialized_end=1415
+ _GETGLOBALMODELRESPONSE._serialized_start=1417
+ _GETGLOBALMODELRESPONSE._serialized_end=1521
+ _HEARTBEAT._serialized_start=1523
+ _HEARTBEAT._serialized_end=1564
+ _CLIENTAVAILABLEMESSAGE._serialized_start=1566
+ _CLIENTAVAILABLEMESSAGE._serialized_end=1653
+ _LISTCLIENTSREQUEST._serialized_start=1655
+ _LISTCLIENTSREQUEST._serialized_end=1737
+ _CLIENTLIST._serialized_start=1739
+ _CLIENTLIST._serialized_end=1781
+ _CLIENT._serialized_start=1783
+ _CLIENT._serialized_end=1831
+ _REASSIGNREQUEST._serialized_start=1833
+ _REASSIGNREQUEST._serialized_end=1942
+ _RECONNECTREQUEST._serialized_start=1944
+ _RECONNECTREQUEST._serialized_end=2043
+ _PARAMETER._serialized_start=2045
+ _PARAMETER._serialized_end=2084
+ _CONTROLREQUEST._serialized_start=2086
+ _CONTROLREQUEST._serialized_end=2170
+ _CONTROLRESPONSE._serialized_start=2172
+ _CONTROLRESPONSE._serialized_end=2242
+ _REPORTRESPONSE._serialized_start=2244
+ _REPORTRESPONSE._serialized_end=2326
+ _CONNECTIONREQUEST._serialized_start=2328
+ _CONNECTIONREQUEST._serialized_end=2347
+ _CONNECTIONRESPONSE._serialized_start=2349
+ _CONNECTIONRESPONSE._serialized_end=2409
+ _MODELSERVICE._serialized_start=2964
+ _MODELSERVICE._serialized_end=3086
+ _CONTROL._serialized_start=3089
+ _CONTROL._serialized_end=3386
+ _REDUCER._serialized_start=3388
+ _REDUCER._serialized_end=3474
+ _CONNECTOR._serialized_start=3477
+ _CONNECTOR._serialized_end=3904
+ _COMBINER._serialized_start=3907
+ _COMBINER._serialized_end=4509
# @@protoc_insertion_point(module_scope)
diff --git a/fedn/fedn/common/net/grpc/fedn_pb2_grpc.py b/fedn/fedn/common/net/grpc/fedn_pb2_grpc.py
index 7cf017b34..9590e2b5c 100644
--- a/fedn/fedn/common/net/grpc/fedn_pb2_grpc.py
+++ b/fedn/fedn/common/net/grpc/fedn_pb2_grpc.py
@@ -2,8 +2,7 @@
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
-from fedn.common.net.grpc import \
- fedn_pb2 as fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2
+from fedn.common.net.grpc import fedn_pb2 as fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2
class ModelServiceStub(object):
@@ -16,15 +15,15 @@ def __init__(self, channel):
channel: A grpc.Channel.
"""
self.Upload = channel.stream_unary(
- '/grpc.ModelService/Upload',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelResponse.FromString,
- )
+ '/grpc.ModelService/Upload',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelResponse.FromString,
+ )
self.Download = channel.unary_stream(
- '/grpc.ModelService/Download',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelResponse.FromString,
- )
+ '/grpc.ModelService/Download',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelResponse.FromString,
+ )
class ModelServiceServicer(object):
@@ -45,60 +44,59 @@ def Download(self, request, context):
def add_ModelServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
- 'Upload': grpc.stream_unary_rpc_method_handler(
- servicer.Upload,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelRequest.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelResponse.SerializeToString,
- ),
- 'Download': grpc.unary_stream_rpc_method_handler(
- servicer.Download,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelRequest.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelResponse.SerializeToString,
- ),
+ 'Upload': grpc.stream_unary_rpc_method_handler(
+ servicer.Upload,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelResponse.SerializeToString,
+ ),
+ 'Download': grpc.unary_stream_rpc_method_handler(
+ servicer.Download,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelResponse.SerializeToString,
+ ),
}
generic_handler = grpc.method_handlers_generic_handler(
- 'grpc.ModelService', rpc_method_handlers)
+ 'grpc.ModelService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
- # This class is part of an EXPERIMENTAL API.
-
+ # This class is part of an EXPERIMENTAL API.
class ModelService(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def Upload(request_iterator,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.stream_unary(request_iterator, target, '/grpc.ModelService/Upload',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelResponse.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelResponse.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Download(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_stream(request, target, '/grpc.ModelService/Download',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelResponse.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelResponse.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
class ControlStub(object):
@@ -111,25 +109,30 @@ def __init__(self, channel):
channel: A grpc.Channel.
"""
self.Start = channel.unary_unary(
- '/grpc.Control/Start',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.FromString,
- )
+ '/grpc.Control/Start',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.FromString,
+ )
self.Stop = channel.unary_unary(
- '/grpc.Control/Stop',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.FromString,
- )
+ '/grpc.Control/Stop',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.FromString,
+ )
self.Configure = channel.unary_unary(
- '/grpc.Control/Configure',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReportResponse.FromString,
- )
+ '/grpc.Control/Configure',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReportResponse.FromString,
+ )
+ self.FlushAggregationQueue = channel.unary_unary(
+ '/grpc.Control/FlushAggregationQueue',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.FromString,
+ )
self.Report = channel.unary_unary(
- '/grpc.Control/Report',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReportResponse.FromString,
- )
+ '/grpc.Control/Report',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReportResponse.FromString,
+ )
class ControlServicer(object):
@@ -153,6 +156,12 @@ def Configure(self, request, context):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
+ def FlushAggregationQueue(self, request, context):
+ """Missing associated documentation comment in .proto file."""
+ context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+ context.set_details('Method not implemented!')
+ raise NotImplementedError('Method not implemented!')
+
def Report(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@@ -162,104 +171,125 @@ def Report(self, request, context):
def add_ControlServicer_to_server(servicer, server):
rpc_method_handlers = {
- 'Start': grpc.unary_unary_rpc_method_handler(
- servicer.Start,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString,
- ),
- 'Stop': grpc.unary_unary_rpc_method_handler(
- servicer.Stop,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString,
- ),
- 'Configure': grpc.unary_unary_rpc_method_handler(
- servicer.Configure,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReportResponse.SerializeToString,
- ),
- 'Report': grpc.unary_unary_rpc_method_handler(
- servicer.Report,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReportResponse.SerializeToString,
- ),
+ 'Start': grpc.unary_unary_rpc_method_handler(
+ servicer.Start,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString,
+ ),
+ 'Stop': grpc.unary_unary_rpc_method_handler(
+ servicer.Stop,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString,
+ ),
+ 'Configure': grpc.unary_unary_rpc_method_handler(
+ servicer.Configure,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReportResponse.SerializeToString,
+ ),
+ 'FlushAggregationQueue': grpc.unary_unary_rpc_method_handler(
+ servicer.FlushAggregationQueue,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.SerializeToString,
+ ),
+ 'Report': grpc.unary_unary_rpc_method_handler(
+ servicer.Report,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReportResponse.SerializeToString,
+ ),
}
generic_handler = grpc.method_handlers_generic_handler(
- 'grpc.Control', rpc_method_handlers)
+ 'grpc.Control', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
- # This class is part of an EXPERIMENTAL API.
-
+ # This class is part of an EXPERIMENTAL API.
class Control(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def Start(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Control/Start',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Stop(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Control/Stop',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Configure(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Control/Configure',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReportResponse.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReportResponse.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+ @staticmethod
+ def FlushAggregationQueue(request,
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
+ return grpc.experimental.unary_unary(request, target, '/grpc.Control/FlushAggregationQueue',
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlResponse.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Report(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Control/Report',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReportResponse.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ControlRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReportResponse.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
class ReducerStub(object):
@@ -272,10 +302,10 @@ def __init__(self, channel):
channel: A grpc.Channel.
"""
self.GetGlobalModel = channel.unary_unary(
- '/grpc.Reducer/GetGlobalModel',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.GetGlobalModelRequest.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.GetGlobalModelResponse.FromString,
- )
+ '/grpc.Reducer/GetGlobalModel',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.GetGlobalModelRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.GetGlobalModelResponse.FromString,
+ )
class ReducerServicer(object):
@@ -290,38 +320,37 @@ def GetGlobalModel(self, request, context):
def add_ReducerServicer_to_server(servicer, server):
rpc_method_handlers = {
- 'GetGlobalModel': grpc.unary_unary_rpc_method_handler(
- servicer.GetGlobalModel,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.GetGlobalModelRequest.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.GetGlobalModelResponse.SerializeToString,
- ),
+ 'GetGlobalModel': grpc.unary_unary_rpc_method_handler(
+ servicer.GetGlobalModel,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.GetGlobalModelRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.GetGlobalModelResponse.SerializeToString,
+ ),
}
generic_handler = grpc.method_handlers_generic_handler(
- 'grpc.Reducer', rpc_method_handlers)
+ 'grpc.Reducer', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
- # This class is part of an EXPERIMENTAL API.
-
+ # This class is part of an EXPERIMENTAL API.
class Reducer(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def GetGlobalModel(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Reducer/GetGlobalModel',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.GetGlobalModelRequest.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.GetGlobalModelResponse.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.GetGlobalModelRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.GetGlobalModelResponse.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
class ConnectorStub(object):
@@ -334,40 +363,40 @@ def __init__(self, channel):
channel: A grpc.Channel.
"""
self.AllianceStatusStream = channel.unary_stream(
- '/grpc.Connector/AllianceStatusStream',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Status.FromString,
- )
+ '/grpc.Connector/AllianceStatusStream',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Status.FromString,
+ )
self.SendStatus = channel.unary_unary(
- '/grpc.Connector/SendStatus',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Status.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- )
+ '/grpc.Connector/SendStatus',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Status.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ )
self.ListActiveClients = channel.unary_unary(
- '/grpc.Connector/ListActiveClients',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ListClientsRequest.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientList.FromString,
- )
+ '/grpc.Connector/ListActiveClients',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ListClientsRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientList.FromString,
+ )
self.AcceptingClients = channel.unary_unary(
- '/grpc.Connector/AcceptingClients',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ConnectionRequest.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ConnectionResponse.FromString,
- )
+ '/grpc.Connector/AcceptingClients',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ConnectionRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ConnectionResponse.FromString,
+ )
self.SendHeartbeat = channel.unary_unary(
- '/grpc.Connector/SendHeartbeat',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Heartbeat.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- )
+ '/grpc.Connector/SendHeartbeat',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Heartbeat.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ )
self.ReassignClient = channel.unary_unary(
- '/grpc.Connector/ReassignClient',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReassignRequest.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- )
+ '/grpc.Connector/ReassignClient',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReassignRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ )
self.ReconnectClient = channel.unary_unary(
- '/grpc.Connector/ReconnectClient',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReconnectRequest.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- )
+ '/grpc.Connector/ReconnectClient',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReconnectRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ )
class ConnectorServicer(object):
@@ -423,170 +452,169 @@ def ReconnectClient(self, request, context):
def add_ConnectorServicer_to_server(servicer, server):
rpc_method_handlers = {
- 'AllianceStatusStream': grpc.unary_stream_rpc_method_handler(
- servicer.AllianceStatusStream,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Status.SerializeToString,
- ),
- 'SendStatus': grpc.unary_unary_rpc_method_handler(
- servicer.SendStatus,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Status.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
- ),
- 'ListActiveClients': grpc.unary_unary_rpc_method_handler(
- servicer.ListActiveClients,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ListClientsRequest.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientList.SerializeToString,
- ),
- 'AcceptingClients': grpc.unary_unary_rpc_method_handler(
- servicer.AcceptingClients,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ConnectionRequest.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ConnectionResponse.SerializeToString,
- ),
- 'SendHeartbeat': grpc.unary_unary_rpc_method_handler(
- servicer.SendHeartbeat,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Heartbeat.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
- ),
- 'ReassignClient': grpc.unary_unary_rpc_method_handler(
- servicer.ReassignClient,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReassignRequest.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
- ),
- 'ReconnectClient': grpc.unary_unary_rpc_method_handler(
- servicer.ReconnectClient,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReconnectRequest.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
- ),
+ 'AllianceStatusStream': grpc.unary_stream_rpc_method_handler(
+ servicer.AllianceStatusStream,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Status.SerializeToString,
+ ),
+ 'SendStatus': grpc.unary_unary_rpc_method_handler(
+ servicer.SendStatus,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Status.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
+ ),
+ 'ListActiveClients': grpc.unary_unary_rpc_method_handler(
+ servicer.ListActiveClients,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ListClientsRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientList.SerializeToString,
+ ),
+ 'AcceptingClients': grpc.unary_unary_rpc_method_handler(
+ servicer.AcceptingClients,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ConnectionRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ConnectionResponse.SerializeToString,
+ ),
+ 'SendHeartbeat': grpc.unary_unary_rpc_method_handler(
+ servicer.SendHeartbeat,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Heartbeat.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
+ ),
+ 'ReassignClient': grpc.unary_unary_rpc_method_handler(
+ servicer.ReassignClient,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReassignRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
+ ),
+ 'ReconnectClient': grpc.unary_unary_rpc_method_handler(
+ servicer.ReconnectClient,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReconnectRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
+ ),
}
generic_handler = grpc.method_handlers_generic_handler(
- 'grpc.Connector', rpc_method_handlers)
+ 'grpc.Connector', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
- # This class is part of an EXPERIMENTAL API.
-
+ # This class is part of an EXPERIMENTAL API.
class Connector(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def AllianceStatusStream(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_stream(request, target, '/grpc.Connector/AllianceStatusStream',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Status.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Status.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def SendStatus(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Connector/SendStatus',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Status.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Status.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ListActiveClients(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Connector/ListActiveClients',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ListClientsRequest.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientList.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ListClientsRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientList.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def AcceptingClients(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Connector/AcceptingClients',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ConnectionRequest.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ConnectionResponse.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ConnectionRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ConnectionResponse.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def SendHeartbeat(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Connector/SendHeartbeat',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Heartbeat.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Heartbeat.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ReassignClient(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Connector/ReassignClient',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReassignRequest.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReassignRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ReconnectClient(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Connector/ReconnectClient',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReconnectRequest.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ReconnectRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
class CombinerStub(object):
@@ -599,45 +627,45 @@ def __init__(self, channel):
channel: A grpc.Channel.
"""
self.ModelUpdateRequestStream = channel.unary_stream(
- '/grpc.Combiner/ModelUpdateRequestStream',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdateRequest.FromString,
- )
+ '/grpc.Combiner/ModelUpdateRequestStream',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdateRequest.FromString,
+ )
self.ModelUpdateStream = channel.unary_stream(
- '/grpc.Combiner/ModelUpdateStream',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdate.FromString,
- )
+ '/grpc.Combiner/ModelUpdateStream',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdate.FromString,
+ )
self.ModelValidationRequestStream = channel.unary_stream(
- '/grpc.Combiner/ModelValidationRequestStream',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidationRequest.FromString,
- )
+ '/grpc.Combiner/ModelValidationRequestStream',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidationRequest.FromString,
+ )
self.ModelValidationStream = channel.unary_stream(
- '/grpc.Combiner/ModelValidationStream',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidation.FromString,
- )
+ '/grpc.Combiner/ModelValidationStream',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidation.FromString,
+ )
self.SendModelUpdateRequest = channel.unary_unary(
- '/grpc.Combiner/SendModelUpdateRequest',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdateRequest.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- )
+ '/grpc.Combiner/SendModelUpdateRequest',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdateRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ )
self.SendModelUpdate = channel.unary_unary(
- '/grpc.Combiner/SendModelUpdate',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdate.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- )
+ '/grpc.Combiner/SendModelUpdate',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdate.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ )
self.SendModelValidationRequest = channel.unary_unary(
- '/grpc.Combiner/SendModelValidationRequest',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidationRequest.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- )
+ '/grpc.Combiner/SendModelValidationRequest',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidationRequest.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ )
self.SendModelValidation = channel.unary_unary(
- '/grpc.Combiner/SendModelValidation',
- request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidation.SerializeToString,
- response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- )
+ '/grpc.Combiner/SendModelValidation',
+ request_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidation.SerializeToString,
+ response_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ )
class CombinerServicer(object):
@@ -695,189 +723,188 @@ def SendModelValidation(self, request, context):
def add_CombinerServicer_to_server(servicer, server):
rpc_method_handlers = {
- 'ModelUpdateRequestStream': grpc.unary_stream_rpc_method_handler(
- servicer.ModelUpdateRequestStream,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdateRequest.SerializeToString,
- ),
- 'ModelUpdateStream': grpc.unary_stream_rpc_method_handler(
- servicer.ModelUpdateStream,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdate.SerializeToString,
- ),
- 'ModelValidationRequestStream': grpc.unary_stream_rpc_method_handler(
- servicer.ModelValidationRequestStream,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidationRequest.SerializeToString,
- ),
- 'ModelValidationStream': grpc.unary_stream_rpc_method_handler(
- servicer.ModelValidationStream,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidation.SerializeToString,
- ),
- 'SendModelUpdateRequest': grpc.unary_unary_rpc_method_handler(
- servicer.SendModelUpdateRequest,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdateRequest.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
- ),
- 'SendModelUpdate': grpc.unary_unary_rpc_method_handler(
- servicer.SendModelUpdate,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdate.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
- ),
- 'SendModelValidationRequest': grpc.unary_unary_rpc_method_handler(
- servicer.SendModelValidationRequest,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidationRequest.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
- ),
- 'SendModelValidation': grpc.unary_unary_rpc_method_handler(
- servicer.SendModelValidation,
- request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidation.FromString,
- response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
- ),
+ 'ModelUpdateRequestStream': grpc.unary_stream_rpc_method_handler(
+ servicer.ModelUpdateRequestStream,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdateRequest.SerializeToString,
+ ),
+ 'ModelUpdateStream': grpc.unary_stream_rpc_method_handler(
+ servicer.ModelUpdateStream,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdate.SerializeToString,
+ ),
+ 'ModelValidationRequestStream': grpc.unary_stream_rpc_method_handler(
+ servicer.ModelValidationRequestStream,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidationRequest.SerializeToString,
+ ),
+ 'ModelValidationStream': grpc.unary_stream_rpc_method_handler(
+ servicer.ModelValidationStream,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidation.SerializeToString,
+ ),
+ 'SendModelUpdateRequest': grpc.unary_unary_rpc_method_handler(
+ servicer.SendModelUpdateRequest,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdateRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
+ ),
+ 'SendModelUpdate': grpc.unary_unary_rpc_method_handler(
+ servicer.SendModelUpdate,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdate.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
+ ),
+ 'SendModelValidationRequest': grpc.unary_unary_rpc_method_handler(
+ servicer.SendModelValidationRequest,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidationRequest.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
+ ),
+ 'SendModelValidation': grpc.unary_unary_rpc_method_handler(
+ servicer.SendModelValidation,
+ request_deserializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidation.FromString,
+ response_serializer=fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.SerializeToString,
+ ),
}
generic_handler = grpc.method_handlers_generic_handler(
- 'grpc.Combiner', rpc_method_handlers)
+ 'grpc.Combiner', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
- # This class is part of an EXPERIMENTAL API.
-
+ # This class is part of an EXPERIMENTAL API.
class Combiner(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def ModelUpdateRequestStream(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_stream(request, target, '/grpc.Combiner/ModelUpdateRequestStream',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdateRequest.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdateRequest.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ModelUpdateStream(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_stream(request, target, '/grpc.Combiner/ModelUpdateStream',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdate.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdate.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ModelValidationRequestStream(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_stream(request, target, '/grpc.Combiner/ModelValidationRequestStream',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidationRequest.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidationRequest.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ModelValidationStream(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_stream(request, target, '/grpc.Combiner/ModelValidationStream',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidation.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ClientAvailableMessage.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidation.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def SendModelUpdateRequest(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Combiner/SendModelUpdateRequest',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdateRequest.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdateRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def SendModelUpdate(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Combiner/SendModelUpdate',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdate.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelUpdate.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def SendModelValidationRequest(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Combiner/SendModelValidationRequest',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidationRequest.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidationRequest.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def SendModelValidation(request,
- target,
- options=(),
- channel_credentials=None,
- call_credentials=None,
- insecure=False,
- compression=None,
- wait_for_ready=None,
- timeout=None,
- metadata=None):
+ target,
+ options=(),
+ channel_credentials=None,
+ call_credentials=None,
+ insecure=False,
+ compression=None,
+ wait_for_ready=None,
+ timeout=None,
+ metadata=None):
return grpc.experimental.unary_unary(request, target, '/grpc.Combiner/SendModelValidation',
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidation.SerializeToString,
- fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
- options, channel_credentials,
- insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.ModelValidation.SerializeToString,
+ fedn_dot_common_dot_net_dot_grpc_dot_fedn__pb2.Response.FromString,
+ options, channel_credentials,
+ insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
diff --git a/fedn/fedn/network/combiner/interfaces.py b/fedn/fedn/network/combiner/interfaces.py
index 832c5fdfa..d70fc80d0 100644
--- a/fedn/fedn/network/combiner/interfaces.py
+++ b/fedn/fedn/network/combiner/interfaces.py
@@ -51,7 +51,7 @@ def get_channel(self):
class CombinerInterface:
- """ Interface for the Combiner (server).
+ """ Interface for the Combiner (aggregation server).
Abstraction on top of the gRPC server servicer.
"""
@@ -220,6 +220,23 @@ def configure(self, config=None):
else:
raise
+ def flush_model_update_queue(self):
+ """ Reset the model update queue on the combiner. """
+
+ channel = Channel(self.address, self.port,
+ self.certificate).get_channel()
+ control = rpc.ControlStub(channel)
+
+ request = fedn.ControlRequest()
+
+ try:
+ control.FlushAggregationQueue(request)
+ except grpc.RpcError as e:
+ if e.code() == grpc.StatusCode.UNAVAILABLE:
+ raise CombinerUnavailableError
+ else:
+ raise
+
def submit(self, config):
""" Submit a compute plan to the combiner.
diff --git a/fedn/fedn/network/combiner/round.py b/fedn/fedn/network/combiner/round.py
index 6ae7a92cc..a19adc9db 100644
--- a/fedn/fedn/network/combiner/round.py
+++ b/fedn/fedn/network/combiner/round.py
@@ -118,7 +118,6 @@ def waitforit(self, config, buffer_size=100, polling_interval=0.1):
"""
time_window = float(config['round_timeout'])
- # buffer_size = int(config['buffer_size'])
tt = 0.0
while tt < time_window:
@@ -150,8 +149,14 @@ def _training_round(self, config, clients):
# Request model updates from all active clients.
self.server.request_model_update(config, clients=clients)
+ # If buffer_size is -1 (default), the round terminates when/if all clients have completed.
+ if int(config['buffer_size']) == -1:
+ buffer_size = len(clients)
+ else:
+ buffer_size = int(config['buffer_size'])
+
# Wait / block until the round termination policy has been met.
- self.waitforit(config, buffer_size=len(clients))
+ self.waitforit(config, buffer_size=buffer_size)
tic = time.time()
model = None
@@ -159,7 +164,6 @@ def _training_round(self, config, clients):
try:
helper = get_helper(config['helper_type'])
- # print config delete_models_storage
print("ROUNDCONTROL: Config delete_models_storage: {}".format(config['delete_models_storage']), flush=True)
if config['delete_models_storage'] == 'True':
delete_models = True
diff --git a/fedn/fedn/network/combiner/server.py b/fedn/fedn/network/combiner/server.py
index ff0134d6b..f5449a375 100644
--- a/fedn/fedn/network/combiner/server.py
+++ b/fedn/fedn/network/combiner/server.py
@@ -371,6 +371,19 @@ def __register_heartbeat(self, client):
self.__join_client(client)
self.clients[client.name]["lastseen"] = datetime.now()
+ def flush_model_update_queue(self):
+ """Clear the model update queue (aggregator). """
+
+ q = self.control.aggregator.model_updates
+ try:
+ with q.mutex:
+ q.queue.clear()
+ q.all_tasks_done.notify_all()
+ q.unfinished_tasks = 0
+ return True
+ except Exception:
+ return False
+
#####################################################################################################################
# Control Service
@@ -400,6 +413,9 @@ def Start(self, control: fedn.ControlRequest, context):
return response
+ # RPCs related to remote configuration of the server, round controller,
+ # aggregator and their states.
+
def Configure(self, control: fedn.ControlRequest, context):
""" Configure the Combiner.
@@ -416,6 +432,29 @@ def Configure(self, control: fedn.ControlRequest, context):
response = fedn.ControlResponse()
return response
+ def FlushAggregationQueue(self, control: fedn.ControlRequest, context):
+ """ Flush the queue.
+
+ :param control: the control request
+ :type control: :class:`fedn.common.net.grpc.fedn_pb2.ControlRequest`
+ :param context: the context (unused)
+ :type context: :class:`grpc._server._Context`
+ :return: the control response
+ :rtype: :class:`fedn.common.net.grpc.fedn_pb2.ControlResponse`
+ """
+
+ status = self.flush_model_update_queue()
+
+ response = fedn.ControlResponse()
+ if status:
+ response.message = 'Success'
+ else:
+ response.message = 'Failed'
+
+ return response
+
+ ##############################################################################
+
def Stop(self, control: fedn.ControlRequest, context):
""" TODO: Not yet implemented.
@@ -494,25 +533,6 @@ def Report(self, control: fedn.ControlRequest, context):
#####################################################################################################################
- def AllianceStatusStream(self, response, context):
- """ A server stream RPC endpoint that emits status messages.
-
- :param response: the response
- :type response: :class:`fedn.common.net.grpc.fedn_pb2.Response`
- :param context: the context (unused)
- :type context: :class:`grpc._server._Context`"""
- status = fedn.Status(
- status="Client {} connecting to AllianceStatusStream.".format(response.sender))
- status.log_level = fedn.Status.INFO
- status.sender.name = self.id
- status.sender.role = role_to_proto_role(self.role)
- self._subscribe_client_to_queue(response.sender, fedn.Channel.STATUS)
- q = self.__get_queue(response.sender, fedn.Channel.STATUS)
- self._send_status(status)
-
- while True:
- yield q.get()
-
def SendStatus(self, status: fedn.Status, context):
""" A client stream RPC endpoint that accepts status messages.
diff --git a/fedn/fedn/network/controller/__init__.py b/fedn/fedn/network/controller/__init__.py
new file mode 100644
index 000000000..e69de29bb
diff --git a/fedn/fedn/network/controller/control.py b/fedn/fedn/network/controller/control.py
index 7929f2892..68e4623e1 100644
--- a/fedn/fedn/network/controller/control.py
+++ b/fedn/fedn/network/controller/control.py
@@ -77,18 +77,23 @@ def session(self, config):
print("Controller already in INSTRUCTING state. A session is in progress.", flush=True)
return
+ if not self.get_latest_model():
+ print("No model in model chain, please provide a seed model!")
+ return
+
self._state = ReducerState.instructing
# Must be called to set info in the db
self.new_session(config)
- if not self.get_latest_model():
- print("No model in model chain, please provide a seed model!")
-
self._state = ReducerState.monitoring
last_round = int(self.get_latest_round_id())
+ # Clear potential stragglers/old model updates at combiners
+ for combiner in self.network.get_combiners():
+ combiner.flush_model_update_queue()
+
# Execute the rounds in this session
for round in range(1, int(config['rounds'] + 1)):
# Increment the round number
@@ -179,7 +184,7 @@ def round(self, session_config, round_id):
else:
# Print every 10 seconds based on value of wait
if wait % 10 == 0:
- print("CONTROL: Round not found! Waiting...", flush=True)
+ print("CONTROL: Waiting for round to complete...", flush=True)
if wait >= session_config['round_timeout']:
print("CONTROL: Round timeout! Exiting round...", flush=True)
break
diff --git a/fedn/fedn/network/dashboard/restservice.py b/fedn/fedn/network/dashboard/restservice.py
index b951fb83d..5782ff088 100644
--- a/fedn/fedn/network/dashboard/restservice.py
+++ b/fedn/fedn/network/dashboard/restservice.py
@@ -571,6 +571,7 @@ def control():
if request.method == 'POST':
# Get session configuration
round_timeout = float(request.form.get('timeout', 180))
+ buffer_size = int(request.form.get('buffer_size', -1))
rounds = int(request.form.get('rounds', 1))
delete_models = request.form.get('delete_models', True)
task = (request.form.get('task', ''))
@@ -601,8 +602,8 @@ def control():
latest_model_id = self.control.get_latest_model()
- config = {'round_timeout': round_timeout, 'model_id': latest_model_id,
- 'rounds': rounds, 'delete_models_storage': delete_models,
+ config = {'round_timeout': round_timeout, 'buffer_size': buffer_size,
+ 'model_id': latest_model_id, 'rounds': rounds, 'delete_models_storage': delete_models,
'clients_required': clients_required,
'clients_requested': clients_requested, 'task': task,
'validate': validate, 'helper_type': helper_type}
diff --git a/fedn/fedn/network/dashboard/templates/index.html b/fedn/fedn/network/dashboard/templates/index.html
index a4182130d..4ac2d182b 100644
--- a/fedn/fedn/network/dashboard/templates/index.html
+++ b/fedn/fedn/network/dashboard/templates/index.html
@@ -305,6 +305,16 @@ New session
+
+
+
diff --git a/fedn/setup.py b/fedn/setup.py
index b6346388f..93eea674d 100644
--- a/fedn/setup.py
+++ b/fedn/setup.py
@@ -2,7 +2,7 @@
setup(
name='fedn',
- version='0.5.0-dev',
+ version='0.5.0',
description="""Scaleout Federated Learning""",
long_description=open('README.md').read(),
long_description_content_type="text/markdown",