|
16 | 16 | # under the License. |
17 | 17 | from __future__ import annotations |
18 | 18 |
|
19 | | -from typing import TYPE_CHECKING, Any, List, Tuple, Optional |
| 19 | +from typing import TYPE_CHECKING, Any, List, Optional, Tuple |
20 | 20 |
|
21 | | -from pyiceberg.table.sorting import NullOrder, SortDirection, SortField, SortOrder, INITIAL_SORT_ORDER_ID, UNSORTED_SORT_ORDER |
| 21 | +from pyiceberg.table.sorting import INITIAL_SORT_ORDER_ID, UNSORTED_SORT_ORDER, NullOrder, SortDirection, SortField, SortOrder |
22 | 22 | from pyiceberg.table.update import ( |
23 | 23 | AddSortOrderUpdate, |
24 | 24 | AssertDefaultSortOrderId, |
@@ -74,7 +74,7 @@ def _add_sort_field( |
74 | 74 | ) |
75 | 75 | ) |
76 | 76 | return self |
77 | | - |
| 77 | + |
78 | 78 | def _reuse_or_create_sort_order_id(self) -> int: |
79 | 79 | """Return the last assigned sort order id or create a new one.""" |
80 | 80 | new_sort_order_id = INITIAL_SORT_ORDER_ID |
@@ -123,7 +123,10 @@ def _commit(self) -> UpdatesAndRequirements: |
123 | 123 | requirements: Tuple[TableRequirement, ...] = () |
124 | 124 | updates: Tuple[TableUpdate, ...] = () |
125 | 125 |
|
126 | | - if self._transaction.table_metadata.default_sort_order_id != new_sort_order.order_id and self._transaction.table_metadata.sort_order_by_id(new_sort_order.order_id) is None: |
| 126 | + if ( |
| 127 | + self._transaction.table_metadata.default_sort_order_id != new_sort_order.order_id |
| 128 | + and self._transaction.table_metadata.sort_order_by_id(new_sort_order.order_id) is None |
| 129 | + ): |
127 | 130 | updates = (AddSortOrderUpdate(sort_order=new_sort_order), SetDefaultSortOrderUpdate(sort_order_id=-1)) |
128 | 131 | else: |
129 | 132 | updates = (SetDefaultSortOrderUpdate(sort_order_id=new_sort_order.order_id),) |
|
0 commit comments