Commit 65caafa4 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Service component: 

- Added RecomputeConnections RPC to client and skeleton in servicer
parent d92e84f1

src/service/client/ServiceClient.py

+7 −0
Original line number Diff line number Diff line
@@ -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

src/service/service/ServiceServiceServicerImpl.py

+5 −0
Original line number Diff line number Diff line
@@ -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()