Decide report, retry, wait, or done for a sharded batch run.
No ratings yet0 installs
Generic, domain-agnostic platform skill that reads a batch run's cortex-resource ledger (run.json + shard-<i>.json) and decides whether to fire the reduce/report step, retry failed or missing items, wait, or stop. Reused as-is by any blueprint that adopts the batch fan-out mechanism — not authored per blueprint. See CONTRACT.md for the shard-runner contract.
batchfan-outreconcileplatform
Versions
v1# Changelog
## v1
- Initial release: generic ledger (`batch_ledger.py`) + decision logic
(`reconcile.py`) for the batch fan-out mechanism.
- `decide` returns `report | retry | wait | done`; retries `failed` and missing
(crashed-shard) items after the run's deadline, bounded by `MAX_ATTEMPTS = 3`;
reports `partial` once attempts are exhausted.
- Documents the shard-runner contract (`CONTRACT.md`) that any blueprint's shard
skill must obey to plug into this reconciler.7/22/2026