Skip to content

Commit f39a2f7

Browse files
committed
Simplify logic, thanks!
1 parent 4d24d0b commit f39a2f7

1 file changed

Lines changed: 5 additions & 7 deletions

File tree

pyiceberg/table/__init__.py

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -291,8 +291,6 @@ def _apply(self, updates: Tuple[TableUpdate, ...], requirements: Tuple[TableRequ
291291

292292
if self._autocommit:
293293
self.commit_transaction()
294-
self._updates = ()
295-
self._requirements = ()
296294

297295
return self
298296

@@ -774,11 +772,11 @@ def commit_transaction(self) -> Table:
774772
updates=self._updates,
775773
requirements=self._requirements,
776774
)
777-
self._updates = ()
778-
self._requirements = ()
779-
return self._table
780-
else:
781-
return self._table
775+
776+
self._updates = ()
777+
self._requirements = ()
778+
779+
return self._table
782780

783781

784782
class CreateTableTransaction(Transaction):

0 commit comments

Comments
 (0)