write_filq_historical_reads

Documentation for eth_defi.tokenised_fund.sygnum.backfill.write_filq_historical_reads function.

write_filq_historical_reads(path, reads, start_block)

Atomically replace FILQ rows in the shared raw price Parquet.

Existing unrelated chains, vaults, rows before start_block and native protocol columns are retained. Schema migration failures propagate so a corrupt production Parquet can never be silently discarded.

Parameters

• path (pathlib.Path) – Shared uncleaned vault-price Parquet path.

• reads (list[eth_defi.vault.base.VaultHistoricalRead]) – Fresh FILQ event-derived rows.

• start_block (int) – Inclusive replacement boundary.

Returns

Tuple of deleted and inserted row counts.

Return type

tuple[int, int]