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())