pshell_config/pide
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Script execution

Browse Source
This commit is contained in:
gobbo_a
2022-08-26 11:22:36 +02:00
parent cf14da05fb
commit 32bd33dfd4
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
script/local.py
View File

@@ -115,7 +115,7 @@ statistics =None
current_pipeline = None
def start_pipeline(name, parameters, port=DEFAULT_PIPELINE_PORT):
global stop_event, parameter_queue, statistics. current_pipeline, parameter_queue, statistics
global stop_event, parameter_queue, statistics, current_pipeline, parameter_queue, statistics
if name is None:
raise Exception("Pipeline name undefined")
stop_pipeline();
@@ -146,7 +146,14 @@ def stop_pipeline():
parameter_queue = None
statistics =None
def get_pipeline():
return current_pipeline
return current_pipeline
def get_pipeline_msg():
if not get_pipeline():
raise Exception("Pipeline not started")
with source(host="127.0.0.1", port=pipeline_port, mode=SUB, receive_timeout = 3000) as stream:
data = stream.receive()
if not data:
raise Exception("Received None message.")
return data.data