Script execution
This commit is contained in:
1 parent
32bd33dfd4
commit
9c5b3a03c4
1 file changed
-10
@@ -1,17 +1,7 @@
|
||||
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
|
||||
|
||||
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"})
|
||||
|
||||
|
||||
|
||||
msg = get_pipeline_msg().data
|
||||
print (msg.keys())
|
||||
Reference in new issue
Block a user