From d97e685a09c7adc768bfe1f82b4fb243b22367d7 Mon Sep 17 00:00:00 2001
From: gifrerenom <lluis.gifre@cttc.es>
Date: Fri, 13 Sep 2024 14:02:00 +0000
Subject: [PATCH] Pre-merge code cleanup and activation of Telemetry
RequestListener
---
deploy/kafka.sh | 2 +-
src/telemetry/backend/service/TelemetryBackendService.py | 3 +--
2 files changed, 2 insertions(+), 3 deletions(-)
diff --git a/deploy/kafka.sh b/deploy/kafka.sh
index f86108011..0483bce15 100755
--- a/deploy/kafka.sh
+++ b/deploy/kafka.sh
@@ -78,7 +78,7 @@ function kafka_deploy() {
echo "Apache Kafka"
echo ">>> Checking if Apache Kafka is deployed ... "
-if [ "$KFK_REDEPLOY" = "YES" ]; then
+if [ "$KFK_REDEPLOY" == "YES" ]; then
echo ">>> Redeploying kafka namespace"
kafka_deploy
elif kubectl get namespace "${KFK_NAMESPACE}" &> /dev/null; then
diff --git a/src/telemetry/backend/service/TelemetryBackendService.py b/src/telemetry/backend/service/TelemetryBackendService.py
index bb9f0a314..95662969b 100755
--- a/src/telemetry/backend/service/TelemetryBackendService.py
+++ b/src/telemetry/backend/service/TelemetryBackendService.py
@@ -50,9 +50,8 @@ class TelemetryBackendService(GenericGrpcService):
'auto.offset.reset' : 'latest'})
self.running_threads = {}
- def RunRequestListener(self)->bool:
+ def install_servicers(self):
threading.Thread(target=self.RequestListener).start()
- return True
def RequestListener(self):
"""
--
GitLab