From 271e66432e51ed3d69385b94cd3930b9e330bff6 Mon Sep 17 00:00:00 2001
From: eveleighoj <35256612+eveleighoj@users.noreply.github.com>
Date: Thu, 5 Dec 2024 11:36:18 +0000
Subject: [PATCH] correct input for csv to pq

---
 digital_land/commands.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/digital_land/commands.py b/digital_land/commands.py
index dd0d9aeb..70d6e124 100644
--- 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",
     )