From a94fe1fdfe078db28a729adf2b177f17632e5aaa Mon Sep 17 00:00:00 2001
From: gifrerenom <lluis.gifre@cttc.es>
Date: Fri, 13 Sep 2024 16:43:13 +0000
Subject: [PATCH] Pre-merge Cosmetic changes
---
src/telemetry/backend/service/__main__.py | 15 ++++++++++-----
src/telemetry/frontend/service/__main__.py | 8 ++++----
2 files changed, 14 insertions(+), 9 deletions(-)
diff --git a/src/telemetry/backend/service/__main__.py b/src/telemetry/backend/service/__main__.py
index 4ad867331..9ec9e191f 100644
--- a/src/telemetry/backend/service/__main__.py
+++ b/src/telemetry/backend/service/__main__.py
@@ -13,7 +13,8 @@
# limitations under the License.
import logging, signal, sys, threading
-from common.Settings import get_log_level
+from prometheus_client import start_http_server
+from common.Settings import get_log_level, get_metrics_port
from .TelemetryBackendService import TelemetryBackendService
terminate = threading.Event()
@@ -27,13 +28,17 @@ def main():
global LOGGER # pylint: disable=global-statement
log_level = get_log_level()
- logging.basicConfig(level=log_level)
+ logging.basicConfig(level=log_level, format="[%(asctime)s] %(levelname)s:%(name)s:%(message)s")
LOGGER = logging.getLogger(__name__)
signal.signal(signal.SIGINT, signal_handler)
signal.signal(signal.SIGTERM, signal_handler)
- LOGGER.debug('Starting...')
+ LOGGER.info('Starting...')
+
+ # Start metrics server
+ metrics_port = get_metrics_port()
+ start_http_server(metrics_port)
grpc_service = TelemetryBackendService()
grpc_service.start()
@@ -41,10 +46,10 @@ def main():
# Wait for Ctrl+C or termination signal
while not terminate.wait(timeout=1.0): pass
- LOGGER.debug('Terminating...')
+ LOGGER.info('Terminating...')
grpc_service.stop()
- LOGGER.debug('Bye')
+ LOGGER.info('Bye')
return 0
if __name__ == '__main__':
diff --git a/src/telemetry/frontend/service/__main__.py b/src/telemetry/frontend/service/__main__.py
index 74bc6f500..2a6c5dbcf 100644
--- a/src/telemetry/frontend/service/__main__.py
+++ b/src/telemetry/frontend/service/__main__.py
@@ -28,13 +28,13 @@ def main():
global LOGGER # pylint: disable=global-statement
log_level = get_log_level()
- logging.basicConfig(level=log_level)
+ logging.basicConfig(level=log_level, format="[%(asctime)s] %(levelname)s:%(name)s:%(message)s")
LOGGER = logging.getLogger(__name__)
signal.signal(signal.SIGINT, signal_handler)
signal.signal(signal.SIGTERM, signal_handler)
- LOGGER.debug('Starting...')
+ LOGGER.info('Starting...')
# Start metrics server
metrics_port = get_metrics_port()
@@ -46,10 +46,10 @@ def main():
# Wait for Ctrl+C or termination signal
while not terminate.wait(timeout=1.0): pass
- LOGGER.debug('Terminating...')
+ LOGGER.info('Terminating...')
grpc_service.stop()
- LOGGER.debug('Bye')
+ LOGGER.info('Bye')
return 0
if __name__ == '__main__':
--
GitLab