From f565dc83a78f994c3665370d14d3683133c6e7a6 Mon Sep 17 00:00:00 2001 From: Kevin Liu Date: Mon, 25 Mar 2024 09:31:36 -0700 Subject: [PATCH] use .as_arrow() --- pyiceberg/io/pyarrow.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pyiceberg/io/pyarrow.py b/pyiceberg/io/pyarrow.py index 72de14880a..9dbb5e8abc 100644 --- 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(