Searched refs:pipeline_q (Results 1 – 1 of 1) sorted by relevance
2534 pipeline_q = queue.LifoQueue()2544 side_effect=iter([pipeline_q, done_q])