From 80078b217f3d480dab6d23afcecfe4305bf9da02 Mon Sep 17 00:00:00 2001
From: gifrerenom <lluis.gifre@cttc.es>
Date: Wed, 9 Oct 2024 11:05:43 +0000
Subject: [PATCH] Telemetry - Backend:
- Fixed few code issues
---
.../backend/service/TelemetryBackendService.py | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/src/telemetry/backend/service/TelemetryBackendService.py b/src/telemetry/backend/service/TelemetryBackendService.py
index 79a35d343..81ef24481 100755
--- a/src/telemetry/backend/service/TelemetryBackendService.py
+++ b/src/telemetry/backend/service/TelemetryBackendService.py
@@ -106,7 +106,7 @@ class TelemetryBackendService(GenericGrpcService):
Method receives collector request and initiates collecter backend.
"""
# print("Initiating backend for collector: ", collector_id)
- LOGGER.info("Initiating backend for collector: ", collector_id)
+ LOGGER.info("Initiating backend for collector: {:s}".format(str(collector_id)))
start_time = time.time()
while not stop_event.is_set():
if int(collector['duration']) != -1 and time.time() - start_time >= collector['duration']: # condition to terminate backend
@@ -165,9 +165,9 @@ class TelemetryBackendService(GenericGrpcService):
Args: err (KafkaError): Kafka error object.
msg (Message): Kafka message object.
"""
- if err:
- LOGGER.debug('Message delivery failed: {:}'.format(err))
+ if err:
+ LOGGER.error('Message delivery failed: {:}'.format(err))
# print(f'Message delivery failed: {err}')
- else:
- LOGGER.info('Message delivered to topic {:}'.format(msg.topic()))
- # print(f'Message delivered to topic {msg.topic()}')
+ #else:
+ # LOGGER.debug('Message delivered to topic {:}'.format(msg.topic()))
+ # # print(f'Message delivered to topic {msg.topic()}')
--
GitLab