use .as_arrow()

apache · Mar 25, 2024 · f565dc8 · f565dc8
1 parent 5103d8a
commit f565dc8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pyiceberg/io/pyarrow.py b/pyiceberg/io/pyarrow.py
@@ -1784,7 +1784,7 @@ def write_file(io: FileIO, table_metadata: TableMetadata, tasks: Iterator[WriteT
 
     file_path = f'{table_metadata.location}/data/{task.generate_data_file_filename("parquet")}'
     schema = table_metadata.schema()
-    arrow_file_schema = schema_to_pyarrow(schema)
+    arrow_file_schema = schema.as_arrow()
 
     fo = io.new_output(file_path)
     row_group_size = PropertyUtil.property_as_int(