Lines Matching refs:completed_queue
49 completed_queue = manager.Queue()
54 args=(TEST_STAGE, {}, helper_queue, completed_queue, result_queue))
62 # is the mock results are added to the completed_queue before and after the
64 completed_queue.put((9, mock_result[9]))
74 completed_queue.put((2, mock_result[2]))
75 completed_queue.put((1, mock_result[1]))
98 completed_queue = manager.Queue()
110 pipeline_worker.Worker(TEST_STAGE, mock_task, completed_queue,
120 # The tasks, from the completed_queue, should be defined in the
123 helper_input = completed_queue.get()
