From 65caafa4d8178da5df7eb32ca1450578fd0712ba Mon Sep 17 00:00:00 2001
From: gifrerenom <lluis.gifre@cttc.es>
Date: Tue, 16 May 2023 10:26:18 +0000
Subject: [PATCH] Service component:
- Added RecomputeConnections RPC to client and skeleton in servicer
---
src/service/client/ServiceClient.py | 7 +++++++
src/service/service/ServiceServiceServicerImpl.py | 5 +++++
2 files changed, 12 insertions(+)
diff --git a/src/service/client/ServiceClient.py b/src/service/client/ServiceClient.py
index 30ff4f483..e8ea478a3 100644
--- a/src/service/client/ServiceClient.py
+++ b/src/service/client/ServiceClient.py
@@ -65,3 +65,10 @@ class ServiceClient:
response = self.stub.DeleteService(request)
LOGGER.debug('DeleteService result: {:s}'.format(grpc_message_to_json_string(response)))
return response
+
+ @RETRY_DECORATOR
+ def RecomputeConnections(self, request : Service) -> Empty:
+ LOGGER.debug('RecomputeConnections request: {:s}'.format(grpc_message_to_json_string(request)))
+ response = self.stub.RecomputeConnections(request)
+ LOGGER.debug('RecomputeConnections result: {:s}'.format(grpc_message_to_json_string(response)))
+ return response
diff --git a/src/service/service/ServiceServiceServicerImpl.py b/src/service/service/ServiceServiceServicerImpl.py
index 6531376b8..2f25fdeab 100644
--- a/src/service/service/ServiceServiceServicerImpl.py
+++ b/src/service/service/ServiceServiceServicerImpl.py
@@ -168,3 +168,8 @@ class ServiceServiceServicerImpl(ServiceServiceServicer):
tasks_scheduler.compose_from_service(service, is_delete=True)
tasks_scheduler.execute_all()
return Empty()
+
+ @safe_and_metered_rpc_method(METRICS_POOL, LOGGER)
+ def RecomputeConnections(self, request : Service, context : grpc.ServicerContext) -> Empty:
+ raise NotImplementedError()
+ return Empty()
--
GitLab