correct input for csv to pq

digital-land · Dec 5, 2024 · 271e664 · 271e664
1 parent f93068f
commit 271e664
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/digital_land/commands.py b/digital_land/commands.py
@@ -348,7 +348,7 @@ def pipeline_run(
     transformed_parquet_dir = cache_dir / "transformed_parquet" / dataset
     transformed_parquet_dir.mkdir(exist_ok=True, parents=True)
     convert_tranformed_csv_to_pq(
-        input_path=input_path,
+        input_path=output_path,
         output_path=transformed_parquet_dir / f"{resource}.parquet",
     )