Signal all in-progress extract() calls to stop after their current LLM request completes. Does not abort already in-flight HTTP calls, but prevents the next chunk from being submitted.
(self)
| 206 | self._cancelled = threading.Event() |
| 207 | |
| 208 | def cancel(self) -> None: |
| 209 | """Signal all in-progress extract() calls to stop after their current |
| 210 | LLM request completes. Does not abort already in-flight HTTP calls, |
| 211 | but prevents the next chunk from being submitted.""" |
| 212 | self._cancelled.set() |
| 213 | |
| 214 | def extract(self, gz_path: str) -> ExtractionResult: |
| 215 | """Full extraction pipeline: prepare → LLM calls → finalize.""" |
no outgoing calls
no test coverage detected