rotki · yabirgb · Jul 21, 2026 · Jul 21, 2026
diff --git a/airdrops/1inch.csv.gz b/airdrops/1inch.csv.gz
diff --git a/airdrops/convex_airdrop.csv.gz b/airdrops/convex_airdrop.csv.gz
diff --git a/airdrops/cornichon_airdrop.csv.gz b/airdrops/cornichon_airdrop.csv.gz
diff --git a/airdrops/cow_gnosis.csv.gz b/airdrops/cow_gnosis.csv.gz
diff --git a/airdrops/cow_mainnet.csv.gz b/airdrops/cow_mainnet.csv.gz
diff --git a/airdrops/curve_airdrop.csv.gz b/airdrops/curve_airdrop.csv.gz
diff --git a/airdrops/debridge_1.csv.gz b/airdrops/debridge_1.csv.gz
diff --git a/airdrops/degen2_season1.csv.gz b/airdrops/degen2_season1.csv.gz
diff --git a/airdrops/degen2_season2.csv.gz b/airdrops/degen2_season2.csv.gz
diff --git a/airdrops/degen2_season3.csv.gz b/airdrops/degen2_season3.csv.gz
diff --git a/airdrops/degen2_season4.csv.gz b/airdrops/degen2_season4.csv.gz
diff --git a/airdrops/diva.csv.gz b/airdrops/diva.csv.gz
diff --git a/airdrops/ens.csv.gz b/airdrops/ens.csv.gz
diff --git a/airdrops/furucombo_airdrop.csv.gz b/airdrops/furucombo_airdrop.csv.gz
diff --git a/airdrops/grain_iou.csv.gz b/airdrops/grain_iou.csv.gz
diff --git a/airdrops/index_v4.json b/airdrops/index_v4.json
diff --git a/airdrops/lido_airdrop.csv.gz b/airdrops/lido_airdrop.csv.gz
diff --git a/airdrops/myso.csv.gz b/airdrops/myso.csv.gz
diff --git a/airdrops/odos.csv.gz b/airdrops/odos.csv.gz
diff --git a/airdrops/omni.csv.gz b/airdrops/omni.csv.gz
diff --git a/airdrops/op_airdrop_5.csv.gz b/airdrops/op_airdrop_5.csv.gz
diff --git a/airdrops/optimism_4.csv.gz b/airdrops/optimism_4.csv.gz
diff --git a/airdrops/psp.csv.gz b/airdrops/psp.csv.gz
diff --git a/airdrops/saddle_finance.csv.gz b/airdrops/saddle_finance.csv.gz
diff --git a/airdrops/shapeshift.csv.gz b/airdrops/shapeshift.csv.gz
diff --git a/airdrops/shutter.csv.gz b/airdrops/shutter.csv.gz
diff --git a/airdrops/squill_airdrop_1.csv.gz b/airdrops/squill_airdrop_1.csv.gz
diff --git a/airdrops/squill_airdrop_2.csv.gz b/airdrops/squill_airdrop_2.csv.gz
diff --git a/airdrops/squill_airdrop_3.csv.gz b/airdrops/squill_airdrop_3.csv.gz
diff --git a/airdrops/starknet.csv.gz b/airdrops/starknet.csv.gz
diff --git a/airdrops/superfluid_1.csv.gz b/airdrops/superfluid_1.csv.gz
diff --git a/airdrops/tornado.csv.gz b/airdrops/tornado.csv.gz
diff --git a/airdrops/uniswap.csv.gz b/airdrops/uniswap.csv.gz
diff --git a/airdrops/zk.csv.gz b/airdrops/zk.csv.gz
diff --git a/scripts/parquet_to_csv.py b/scripts/parquet_to_csv.py
@@ -0,0 +1,68 @@
+#!/usr/bin/env -S uv run
+# /// script
+# requires-python = ">=3.11"
+# dependencies = [
+#     "polars>=1.0",
+# ]
+# ///
+"""Convert every Parquet file in a directory to a gzip-compressed CSV file."""
+
+import argparse
+import gzip
+from pathlib import Path
+
+import polars as pl
+
+
+DEFAULT_AIRDROPS_DIR = Path(__file__).resolve().parent.parent / "airdrops"
+
+
+def parse_args() -> argparse.Namespace:
+    parser = argparse.ArgumentParser(description=__doc__)
+    parser.add_argument(
+        "directory",
+        nargs="?",
+        type=Path,
+        default=DEFAULT_AIRDROPS_DIR,
+        help="directory containing Parquet files (default: repository airdrops directory)",
+    )
+    return parser.parse_args()
+
+
+def convert_file(parquet_path: Path) -> Path:
+    output_path = parquet_path.with_suffix(".csv.gz")
+    temporary_path = output_path.with_suffix(f"{output_path.suffix}.tmp")
+
+    try:
+        dataframe = pl.read_parquet(parquet_path)
+        with temporary_path.open(mode="wb") as temporary_file:
+            with gzip.GzipFile(
+                filename="",
+                mode="wb",
+                fileobj=temporary_file,
+                mtime=0,
+            ) as compressed_file:
+                dataframe.write_csv(compressed_file)
+        temporary_path.replace(output_path)
+    finally:
+        temporary_path.unlink(missing_ok=True)
+
+    return output_path
+
+
+def main() -> None:
+    directory = parse_args().directory.expanduser().resolve()
+    if not directory.is_dir():
+        raise SystemExit(f"Directory does not exist: {directory}")
+
+    parquet_paths = sorted(directory.glob("*.parquet"))
+    if not parquet_paths:
+        raise SystemExit(f"No Parquet files found in: {directory}")
+
+    for parquet_path in parquet_paths:
+        output_path = convert_file(parquet_path)
+        print(f"{parquet_path.name} -> {output_path.name}")
+
+
+if __name__ == "__main__":
+    main()