few syntax errors are removed (8cf8288c) · Commits · TFS / controller

src/telemetry_frontend/client/TelemetryFrontendClient.py

+4 −4

Original line number	Diff line number	Diff line
		@@ -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)))