diff --git a/script/local.py b/script/local.py index 81eca04..4dea0a2 100644 --- a/script/local.py +++ b/script/local.py @@ -121,6 +121,7 @@ def start_pipeline(name, parameters, port=DEFAULT_PIPELINE_PORT): raise Exception("Pipeline name undefined") stop_pipeline(); current_pipeline = name + pipeline_port = port stop_event = threading.Event() parameter_queue = queue.Queue() statistics = Namespace()