ds_provider_xledger_py_lib.dataset.engines

File: __init__.py Region: ds_provider_xledger_py_lib/dataset/engines

Description

Dataset execution engines.

Submodules

• ds_provider_xledger_py_lib.dataset.engines.read

Classes

ReadEngine

Execute Xledger read requests including pagination handling.

Package Contents

class ds_provider_xledger_py_lib.dataset.engines.ReadEngine

Execute Xledger read requests including pagination handling.

This engine is intentionally stateful: - output accumulates collected rows page-by-page - checkpoint tracks the last valid pagination state

connection: ds_protocol_http_py_lib.utils.http.provider.Http

host: str

deserializer: ds_provider_xledger_py_lib.serde.deserializer.XledgerDeserializer

metadata: ds_provider_xledger_py_lib.utils.introspection.MetaData

output: list[pandas.DataFrame] = []

checkpoint: Checkpoint

execute(*, read_settings: ds_provider_xledger_py_lib.dataset.xledger.XledgerReadSettings, checkpoint: dict[str, Any] | None = None) → None

Execute read flow and update output/checkpoint state.

Parameters:

• read_settings – Effective read settings for query rendering/pagination.

• checkpoint – Existing checkpoint state to continue from.