Skip to content
Snippets Groups Projects
Commit 26865f93 authored by Waleed Akbar's avatar Waleed Akbar
Browse files

Commented previous DaskStreamer import.

- To be updated later.
parent 8c1d7155
No related branches found
No related tags found
1 merge request!317Resolve "(CTTC) Analytics Module Enhancements"
...@@ -23,7 +23,7 @@ from confluent_kafka import KafkaError ...@@ -23,7 +23,7 @@ from confluent_kafka import KafkaError
from common.Constants import ServiceNameEnum from common.Constants import ServiceNameEnum
from common.Settings import get_service_port_grpc from common.Settings import get_service_port_grpc
from threading import Thread, Event from threading import Thread, Event
from .DaskStreaming import DaskStreamer # from .DaskStreaming import DaskStreamer
LOGGER = logging.getLogger(__name__) LOGGER = logging.getLogger(__name__)
...@@ -89,7 +89,7 @@ class AnalyticsBackendService(GenericGrpcService): ...@@ -89,7 +89,7 @@ class AnalyticsBackendService(GenericGrpcService):
try: try:
stop_event = Event() stop_event = Event()
thread = Thread( thread = Thread(
target=DaskStreamer, target=None, # DaskStreamer,
# args=(analyzer_uuid, kpi_list, oper_list, thresholds, stop_event), # args=(analyzer_uuid, kpi_list, oper_list, thresholds, stop_event),
args=(analyzer['output_kpis'][0] , kpi_list, thresholds, stop_event), args=(analyzer['output_kpis'][0] , kpi_list, thresholds, stop_event),
kwargs={ kwargs={
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment