merge_into_uncleaned_parquet
Documentation for eth_defi.grvt.vault_data_export.merge_into_uncleaned_parquet function.
- merge_into_uncleaned_parquet(db, parquet_path)
Merge GRVT daily prices into the uncleaned Parquet file.
Writes GRVT 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 GRVT rows (chain == 325), appends fresh GRVT 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.grvt.daily_metrics.GRVTDailyMetricsDatabase) – The GRVT daily metrics database.
parquet_path (pathlib.Path) – Path to the uncleaned Parquet file (typically
vault-prices-1h.parquet).
- Returns
The combined DataFrame.
- Return type