Loading src/common/tests/MockServicerImpl_Monitoring.py +3 −1 Original line number Diff line number Diff line Loading @@ -15,6 +15,7 @@ import grpc, logging from queue import Queue from typing import Optional from common.proto.context_pb2 import Empty from common.proto.monitoring_pb2 import Kpi from common.proto.monitoring_pb2_grpc import MonitoringServiceServicer Loading @@ -23,8 +24,9 @@ from common.tools.grpc.Tools import grpc_message_to_json_string LOGGER = logging.getLogger(__name__) class MockServicerImpl_Monitoring(MonitoringServiceServicer): def __init__(self, queue_samples : Queue): def __init__(self, queue_samples : Optional[Queue] = None): LOGGER.info('[__init__] Creating Servicer...') if queue_samples is None: queue_samples = Queue() self.queue_samples = queue_samples LOGGER.info('[__init__] Servicer Created') Loading Loading
src/common/tests/MockServicerImpl_Monitoring.py +3 −1 Original line number Diff line number Diff line Loading @@ -15,6 +15,7 @@ import grpc, logging from queue import Queue from typing import Optional from common.proto.context_pb2 import Empty from common.proto.monitoring_pb2 import Kpi from common.proto.monitoring_pb2_grpc import MonitoringServiceServicer Loading @@ -23,8 +24,9 @@ from common.tools.grpc.Tools import grpc_message_to_json_string LOGGER = logging.getLogger(__name__) class MockServicerImpl_Monitoring(MonitoringServiceServicer): def __init__(self, queue_samples : Queue): def __init__(self, queue_samples : Optional[Queue] = None): LOGGER.info('[__init__] Creating Servicer...') if queue_samples is None: queue_samples = Queue() self.queue_samples = queue_samples LOGGER.info('[__init__] Servicer Created') Loading