diff --git a/script/test/test_thread.py b/script/test/test_thread.py index 9e529d9..68ea4b9 100644 --- a/script/test/test_thread.py +++ b/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")