diff --git a/src/telemetry_frontend/client/TelemetryFrontendClient.py b/src/telemetry_frontend/client/TelemetryFrontendClient.py index 9ca19bb8ce1aabcaa645d4599151caefbc3e52a0..a215dd408bcd17089045f6631819d89c467b19e0 100644 --- a/src/telemetry_frontend/client/TelemetryFrontendClient.py +++ b/src/telemetry_frontend/client/TelemetryFrontendClient.py @@ -20,7 +20,7 @@ from common.proto.context_pb2 import Empty from common.tools.grpc.Tools import grpc_message_to_json_string from common.tools.client.RetryDecorator import retry, delay_exponential from common.proto.telemetry_frontend_pb2_grpc import TelemetryFrontendServiceStub -from comment.proto.telemetry_frontend_pb2 import Collector, CollectorId, CollectorFilter, CollectorList +from common.proto.telemetry_frontend_pb2 import Collector, CollectorId, CollectorFilter, CollectorList LOGGER = logging.getLogger(__name__) MAX_RETRIES = 10 @@ -48,21 +48,21 @@ class TelemetryFrontendClient: self.stub = None @RETRY_DECORATOR - def StartCollector(self, request : Collector) --> CollectorId: + def StartCollector(self, request : Collector) -> CollectorId: LOGGER.debug('StartCollector: {:s}'.format(grpc_message_to_json_string(request))) response = self.stub.StartCollector(request) LOGGER.debug('StartCollector result: {:s}'.format(grpc_message_to_json_string(response))) return response @RETRY_DECORATOR - def StopCollector(self, request : CollectorId) --> Empty: + def StopCollector(self, request : CollectorId) -> Empty: LOGGER.debug('StopCollector: {:s}'.format(grpc_message_to_json_string(request))) response = self.stub.StopCollector(request) LOGGER.debug('StopCollector result: {:s}'.format(grpc_message_to_json_string(response))) return response @RETRY_DECORATOR - def SelectCollectors(self, request : CollectorFilter) --> CollectorList: + def SelectCollectors(self, request : CollectorFilter) -> CollectorList: LOGGER.debug('SelectCollectors: {:s}'.format(grpc_message_to_json_string(request))) response = self.stub.SelectCollectors(request) LOGGER.debug('SelectCollectors result: {:s}'.format(grpc_message_to_json_string(response)))