Do ruff formatting

delta-io · Feb 9, 2024 · 4d2c18c · 4d2c18c
1 parent bf796d3
commit 4d2c18c
Showing 1 changed file with 12 additions and 9 deletions.
diff --git a/python/deltalake/writer.py b/python/deltalake/writer.py
@@ -100,7 +100,8 @@ def write_deltalake(
     large_dtypes: bool = ...,
     engine: Literal["pyarrow"] = ...,
     custom_metadata: Optional[Dict[str, str]] = ...,
-) -> None: ...
+) -> None:
+    ...
 
 
 @overload
@@ -127,7 +128,8 @@ def write_deltalake(
     engine: Literal["rust"],
     writer_properties: WriterProperties = ...,
     custom_metadata: Optional[Dict[str, str]] = ...,
-) -> None: ...
+) -> None:
+    ...
 
 
 @overload
@@ -155,7 +157,8 @@ def write_deltalake(
     engine: Literal["rust"],
     writer_properties: WriterProperties = ...,
     custom_metadata: Optional[Dict[str, str]] = ...,
-) -> None: ...
+) -> None:
+    ...
 
 
 def write_deltalake(
@@ -414,12 +417,12 @@ def check_data_is_aligned_with_partition_filtering(
             ) -> None:
                 if table is None:
                     return
-                existed_partitions: FrozenSet[FrozenSet[Tuple[str, Optional[str]]]] = (
-                    table._table.get_active_partitions()
-                )
-                allowed_partitions: FrozenSet[FrozenSet[Tuple[str, Optional[str]]]] = (
-                    table._table.get_active_partitions(partition_filters)
-                )
+                existed_partitions: FrozenSet[
+                    FrozenSet[Tuple[str, Optional[str]]]
+                ] = table._table.get_active_partitions()
+                allowed_partitions: FrozenSet[
+                    FrozenSet[Tuple[str, Optional[str]]]
+                ] = table._table.get_active_partitions(partition_filters)
                 partition_values = pa.RecordBatch.from_arrays(
                     [
                         batch.column(column_name)