From c5d44eeb0bc719c02c382b953103024e38a21904 Mon Sep 17 00:00:00 2001 From: ion-elgreco <15728914+ion-elgreco@users.noreply.github.com> Date: Sat, 4 Nov 2023 23:24:22 +0100 Subject: [PATCH] formatting --- python/deltalake/writer.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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="/",