solutions_backend.sensors.runner

Cursor-safe source runner over the complete order router.

Classes

Bases: Protocol

advance(state: SensorCursorState, **kwargs) -> SensorCursorState

get_or_create(**kwargs) -> SensorCursorState

Process an ordered provider batch; advance only after every terminal receipt.

run_once() -> SensorRunResult

Bases: Protocol

initial_cursor() -> dict[str, object]

read(cursor: SensorCursorState) -> SourceBatch