(gz_path: str)
| 202 | batch = BatchResult() |
| 203 | |
| 204 | def _do_one(gz_path: str) -> ExtractionResult: |
| 205 | if on_start: |
| 206 | on_start(gz_path) |
| 207 | return _extract_one(extractor, gz_path) |
| 208 | |
| 209 | executor = concurrent.futures.ThreadPoolExecutor(max_workers=jobs) |
| 210 | try: |
nothing calls this directly
no test coverage detected