|
|
@@ -15,8 +15,7 @@ def main():
|
|
|
annexI = party in r.annex_one_reader.parties["code"].values
|
|
|
subdir = "annexI" if annexI else "non-annexI"
|
|
|
directory = ROOT_DIR / "data" / subdir
|
|
|
- if not directory.exists():
|
|
|
- directory.mkdir()
|
|
|
+ directory.mkdir(parents=True, exist_ok=True)
|
|
|
df.to_csv(directory / f"{party}.csv.gz", compression="gzip")
|
|
|
df.to_parquet(directory / f"{party}.parquet", compression="brotli")
|
|
|
|
