fix(runtime): poll batches during ingestion - #17
Conversation
Reconcile active batches at durable chunk boundaries so completed remote work releases local enqueue capacity before source exhaustion.
ProofTested immutable source SHA: Baseline: Exact deterministic flows and results
uv run pytest -q --no-cov \
tests/unit/test_batchor_runtime_ingestion.py::test_ingest_job_items_polls_on_cadence_before_chunk_submission \
tests/unit/test_batchor_runtime_ingestion.py::test_ingest_job_items_does_not_poll_without_active_batches \
tests/unit/test_batchor_runtime_ingestion.py::test_ingest_job_items_stops_checkpointed_ingestion_when_poll_changes_control \
tests/unit/test_batchor_runtime_ingestion.py::test_ingest_job_items_stops_checkpointed_ingestion_when_poll_records_backoff \
tests/integration/test_batchor_runner.py::test_ingestion_poll_releases_capacity_before_source_is_fully_materializedResult: exit 0; six cases passed (the control-state case is parameterized for pause and cancellation).
uv run pytest -q --no-cov \
tests/integration/test_batchor_runner.py::test_ingestion_poll_releases_capacity_before_source_is_fully_materializedBASE result: exit 1; only
uv run pytest -q
uv run ty check src
uv run mkdocs build --strict
uv build --out-dir <temporary-output-directory>
git diff --check 602be52ebe758baac53fc5fb8e322dd2eab57330...d6a796ccbd544789253bfb8d9f960e23237c7d19Results:
GitHub CI is green on Criterion → evidence
Public-safety and retentionSanitized before posting: machine-local checkout paths, virtual-environment paths, pytest temporary paths, local scratch-directory names, and local run identifiers are omitted. No credentials, DSNs, tokens, source data, or personal data were used or retained. This PR comment is the durable evidence summary; retention owner is the repository/GitHub PR history. Temporary local test checkouts and build artifacts are disposable and are not required to interpret the retained evidence. |
Summary
Test plan
Proof
Source SHA: d6a796c
Commit-bound criterion evidence will be added after the independent proof pass.