Searched refs:pipeline_mgr (Results 1 – 1 of 1) sorted by relevance
3336 def pipeline_mgr(self, pipeline, done_queue, lock, results): member in TestSuite3375 p = Process(target=self.pipeline_mgr, args=(pipeline, done, lock, results, ))
