diff --git a/python/deltalake/writer.py b/python/deltalake/writer.py index ac8409cc38..8bd878e61a 100644 --- a/python/deltalake/writer.py +++ b/python/deltalake/writer.py @@ -346,7 +346,10 @@ def validate_batch(batch: pa.RecordBatch) -> pa.RecordBatch: if file_options is not None: file_options.update(use_compliant_nested_type=False) else: - file_options = pa.dataset.ParquetFileFormat().make_write_options(use_compliant_nested_type=False) + file_options = pa.dataset.ParquetFileFormat().make_write_options( + use_compliant_nested_type=False + ) + ds.write_dataset( data, base_dir="/",