fix: Duplicate schema argument in wr.s3.to_parquet()

Signed-off-by: Anton Kukushkin <[email protected]>
aws · Sep 8, 2023 · 8de843f · 8de843f
1 parent 146b443
commit 8de843f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/awswrangler/s3/_write_parquet.py b/awswrangler/s3/_write_parquet.py
@@ -64,6 +64,8 @@ def _new_writer(
         pyarrow_additional_kwargs["use_dictionary"] = True
     if not pyarrow_additional_kwargs.get("write_statistics"):
         pyarrow_additional_kwargs["write_statistics"] = True
+    if schema:
+        pyarrow_additional_kwargs["schema"] = schema
 
     with open_s3_object(
         path=file_path,