merge_into_uncleaned_parquet
Documentation for eth_defi.hibachi.vault_data_export.merge_into_uncleaned_parquet function.
- merge_into_uncleaned_parquet(db, parquet_path)
Merge Hibachi daily prices into the uncleaned Parquet file.
Writes Hibachi raw data in the same format as the EVM vault scanner, so the standard cleaning pipeline (
process_raw_vault_scan_data()) can process all vaults together.Reads the existing Parquet, removes any prior Hibachi rows (chain == 9997), appends fresh Hibachi daily price rows, and writes back. Idempotent: running twice produces the same result.
If the Parquet file does not exist, creates a new one.
- Parameters
db (eth_defi.hibachi.daily_metrics.HibachiDailyMetricsDatabase) – The Hibachi daily metrics database.
parquet_path (pathlib.Path) – Path to the uncleaned Parquet file (typically
vault-prices-1h.parquet).
- Returns
The combined DataFrame.
- Return type