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:18:31 +02:00
parent fcb1a34d26
commit a60dcd947c
1 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
script/test/test_pipeline2.py
View File

@@ -1,10 +1,17 @@
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.")
print retuern data.data
#viewer.show_stream("tcp://localhost:" + str(DEFAULT_PIPELINE_PORT))
#pipeline_config = PipelineConfig("test_pipeline", parameters={"camera_name": "simulation", "function":"transparent"})
#start_pipeline("test_pipeline", {"camera_name": "simulation", "function":"transparent"})
with source(host="127.0.0.1", port=DEFAULT_PIPELINE_PORT, mode=SUB, receive_timeout = 3000) as stream:
data = stream.receive()
if not data:
raise Exception("Received None message.")
print (data.data.data.keys())
msg = get_pipeline_msg().data
print (msg.keys())