Script execution

script/test/test_thread.py

@@ -7,6 +7,7 @@ from cam_server.pipeline.configuration import PipelineConfig
 from cam_server import CamClient, PipelineClient, ProxyClient, config
 from cam_server.pipeline.types.processing import run as processing_pipeline
 import  multiprocessing
+import time
 
 class Namespace(object):
     def __init__(self, **kwds):
@@ -77,8 +78,9 @@ for port in (12007, 12008):
     parameter_queue = queue.Queue()
     thread = threading.Thread(target=run_pipeline, args=(port,pipeline_config, parameter_queue, stop_event))
     thread.start()
-    data = get_data(port)
-    print ("Received: ", data.keys())
+    #data = get_data(port)
+    #print ("Received: ", data.keys())
+    time.sleep(1.0)
     stop_event.set()
     thread.join(5.0)
     print ("Finished OK")