discovery_wrappers.py 文件源码

def _wait_for_processors_to_free_up(self, max_concurrent_processes):
        while len(active_children()) >= max_concurrent_processes:
            self.logger.debug("Waiting a few seconds for processors to free up")
            time.sleep(0.1)