solutions_backend.sensors.rebuild

Finite historical replay using the exact same router as live sensors.

Classes

`HistoricalRebuildConfigurationError`

Bases: RuntimeError

A rebuild named an absent adapter or one with conflicting source identity.

`HistoricalRebuildCoordinator`

Resolve durable rebuilds to adapters and resume the exact production router.

`execute`

execute(rebuild_id: UUID, max_batches: int = 100) -> HistoricalRebuildState

`get`

get(rebuild_id: UUID) -> HistoricalRebuildState

`plan`

plan(sensor_key: str, window_start: datetime | None, window_end: datetime | None, reprocess_generation: int = 1) -> HistoricalRebuildState

`HistoricalRebuildFailedError`

Bases: RuntimeError

A finite rebuild failed after its durable ledger was updated.

`HistoricalRebuildRunner`

Replay finite pages, checkpointing only terminally admitted batches.

`execute`

execute(state: HistoricalRebuildState, max_batches: int = 100) -> HistoricalRebuildState

`plan`

plan(window_start: datetime | None, window_end: datetime | None, reprocess_generation: int = 1) -> HistoricalRebuildState

`RebuildStore`

Bases: Protocol

`checkpoint`

checkpoint(rebuild_id: UUID, cursor: dict[str, object], seen: int, admitted: int, review: int) -> HistoricalRebuildState

`finish`

finish(rebuild_id: UUID, status: HistoricalRebuildStatus, now: datetime, last_error: str | None = None) -> HistoricalRebuildState

`get`

get(rebuild_id: UUID) -> HistoricalRebuildState

`plan`

plan(rebuild_id: UUID, sensor_key: str, source_kind: SourceKind, source_system: str, source_account: str | None, window_start: datetime | None, window_end: datetime | None, reprocess_generation: int, cursor: dict[str, object], now: datetime) -> HistoricalRebuildState

`start`

start(rebuild_id: UUID, now: datetime) -> HistoricalRebuildState