Sleeps until all the processors are done.
(self)
| 945 | self._processors = filtered_processors |
| 946 | |
| 947 | def wait_until_finished(self): |
| 948 | """Sleeps until all the processors are done.""" |
| 949 | for processor in self._processors.values(): |
| 950 | while not processor.done: |
| 951 | time.sleep(0.1) |
| 952 | |
| 953 | def _collect_results_from_processor(self, processor) -> None: |
| 954 | self.log.debug("Processor for %s finished", processor.file_path) |