diff --git a/src/analytics/backend/service/AnalyticsBackendService.py b/src/analytics/backend/service/AnalyticsBackendService.py
index f3a58feaab8667b266052803dddd1641b8a690f3..38a305aecc61c67ca1f9127c2e7ae9418b656418 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={