migrate_parquet_to_ns

Defined in dccd.storage.migrate

migrate_parquet_to_ns(data_path, *, dry_run=False)[source]

Migrate all Parquet files under data_path to the canonical v3 schema.

Parameters:
data_pathstr or Path

Root data directory.

dry_runbool

If True, only report what would change without modifying any file.

Returns:
list of dict

Per-file report with path, rows, from_schema, to_schema, rescaled (TS s→ns applied) and migrated keys.