use module directly

delta-io · Nov 4, 2023 · 69dfbed · 69dfbed
1 parent c5d44ee
commit 69dfbed
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/deltalake/writer.py b/python/deltalake/writer.py
@@ -346,7 +346,7 @@ 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(
+        file_options = ds.ParquetFileFormat().make_write_options(
             use_compliant_nested_type=False
         )