(self, requirement)
| 390 | self.work_queue.extend(jobs) |
| 391 | |
| 392 | def results(self, requirement): |
| 393 | while self.work_queue and not self.abort_now: |
| 394 | job = self.work_queue.pop() |
| 395 | yield MaybeResult.create_result(job.run(ProcessContext(requirement))) |
| 396 | |
| 397 | |
| 398 | # Global function for multiprocessing, because pickling a static method doesn't |
nothing calls this directly
no test coverage detected