From 26865f9320e8e0935c56fd7e964595e289ca1719 Mon Sep 17 00:00:00 2001
From: Waleed Akbar <wakbar@cttc.es>
Date: Mon, 13 Jan 2025 13:40:41 +0000
Subject: [PATCH] Commented previous DaskStreamer import.

- To be updated later.
---
 src/analytics/backend/service/AnalyticsBackendService.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/analytics/backend/service/AnalyticsBackendService.py b/src/analytics/backend/service/AnalyticsBackendService.py
index f3a58feaa..38a305aec 100755
--- a/src/analytics/backend/service/AnalyticsBackendService.py
+++ b/src/analytics/backend/service/AnalyticsBackendService.py
@@ -23,7 +23,7 @@ from confluent_kafka import KafkaError
 from common.Constants import ServiceNameEnum
 from common.Settings import get_service_port_grpc
 from threading import Thread, Event
-from .DaskStreaming import DaskStreamer
+# from .DaskStreaming import DaskStreamer
 
 LOGGER = logging.getLogger(__name__)
 
@@ -89,7 +89,7 @@ class AnalyticsBackendService(GenericGrpcService):
         try:
             stop_event = Event()
             thread     = Thread(
-                target=DaskStreamer,
+                target=None,  # DaskStreamer,
                 # args=(analyzer_uuid, kpi_list, oper_list, thresholds, stop_event),
                 args=(analyzer['output_kpis'][0] , kpi_list, thresholds, stop_event),
                 kwargs={
-- 
GitLab