Script execution

2022-08-26 11:32:11 +02:00
parent 66686e7740
commit 291581649f
1 changed files with 2 additions and 1 deletions
@@ -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