Function run_sequential

explainshell/extraction/runner.py:149–184

Run extractor on each file sequentially. Callback exceptions are treated as fatal, just like unexpected extractor exceptions.

(
    extractor: Extractor,
    gz_files: list[str],
    on_start: Callable[[str], None] | None = None,
    on_result: Callable[[str, ExtractionResult], None] | None = None,
)

def run_sequential(
    extractor: Extractor,
    gz_files: list[str],
    on_start: Callable[[str], None] | None = None,
    on_result: Callable[[str, ExtractionResult], None] | None = None,
) -> BatchResult:
    """Run extractor on each file sequentially.

    Callback exceptions are treated as fatal, just like unexpected extractor
    exceptions.
    """
    batch = BatchResult()

    for gz_path in gz_files:
        try:
            if on_start:
                on_start(gz_path)

            entry = _extract_one(extractor, gz_path)
            _tally(batch, entry)
            if on_result:
                on_result(gz_path, entry)
        except KeyboardInterrupt:
            logger.info("interrupted by user")
            batch.interrupted = True
            break
        except FatalExtractionError:
            raise
        except Exception as e:
            logger.exception(
                "fatal unexpected exception in callback while processing %s",
                gz_path,
            )
            raise FatalExtractionError(str(e)) from e

    return batch


def run_parallel(