diff --git a/script/local.py b/script/local.py index bf172e1..41d723c 100644 --- a/script/local.py +++ b/script/local.py @@ -117,7 +117,7 @@ pipeline_port = None pipeline_thread = None def start_pipeline(name, parameters, port=PIPELINE_DEFAULT_PORT): - global pipeline_stop_event, pipeline_queue, pipeline_statistics, current_pipeline, pipeline_port, pipeline_thread + global pipeline_stop_event, pipeline_queue, pipeline_statistics, pipeline_name, pipeline_port, pipeline_thread if name is None: raise Exception("Pipeline name undefined") stop_pipeline(); @@ -142,6 +142,7 @@ def stop_pipeline(): try: pipeline_stop_event.set() pipeline_thread.join(5.0) + print ("Stopped pipeline ", pipeline_name) except: traceback.print_exc() pipeline_name = None