Commit 6b70c5f9 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Pre-merge code cleanup

parent 354e02de

src/analytics/backend/service/Streamer.py

+3 −2
Original line number Diff line number Diff line
@@ -25,7 +25,8 @@ from analytics.backend.service.AnalyzerHelper import AnalyzerHelper 
logger = logging.getLogger(__name__)



class DaskStreamer(threading.Thread):

    def __init__(self, key, input_kpis, output_kpis, thresholds,

    def __init__(

        self, key, input_kpis, output_kpis, thresholds,

        batch_size        = 5,

        batch_duration    = None,

        window_size       = None,