Startup

2022-08-26 11:47:56 +02:00
parent 291581649f
commit 05be33b536
1 changed files with 5 additions and 1 deletions
@@ -160,4 +160,8 @@ def get_pipeline_msg():
        data = stream.receive()
        if not data: 
            raise Exception("Received None message.")
-        return data.data    
+        return data.data    
+
+
+def on_system_restart(path):   
+    stop_pipeline()