Skip to content

Commit 26edb5f

Browse files
committed
Ensured DataFrame.write_parquet forwards caller-supplied DataFrameWriteOptions when invoked with ParquetWriterOptions, preserving the write configuration.
1 parent b774b0d commit 26edb5f

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

python/datafusion/dataframe.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1021,7 +1021,11 @@ def write_parquet(
10211021
if compression_level is not None:
10221022
msg = "compression_level should be None when using ParquetWriterOptions"
10231023
raise ValueError(msg)
1024-
self.write_parquet_with_options(path, compression)
1024+
self.write_parquet_with_options(
1025+
path,
1026+
compression,
1027+
write_options=write_options,
1028+
)
10251029
return
10261030

10271031
if isinstance(compression, str):

0 commit comments

Comments
 (0)