()
| 212 | gz_iter = iter(gz_files) |
| 213 | |
| 214 | def _submit_next() -> bool: |
| 215 | gz_path = next(gz_iter, None) |
| 216 | if gz_path is None: |
| 217 | return False |
| 218 | pending.add(executor.submit(_do_one, gz_path)) |
| 219 | return True |
| 220 | |
| 221 | for _ in range(jobs): |
| 222 | if not _submit_next(): |
no test coverage detected