diff --git a/src/service/client/ServiceClient.py b/src/service/client/ServiceClient.py index 30ff4f4838dd52d7010f08a7814ff208afbe92f4..e8ea478a3109d3e006120db9f22966724773b78b 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 6531376b84732b1ec80e335cfc6cd816be944b0a..2f25fdeab38a1cb4d72f9942879c170fbed80b55 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()