We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f39a2f7 commit 54d980dCopy full SHA for 54d980d
1 file changed
pyiceberg/table/__init__.py
@@ -825,11 +825,16 @@ def commit_transaction(self) -> Table:
825
Returns:
826
The table with the updates applied.
827
"""
828
- self._requirements = (AssertCreate(),)
829
- self._table._do_commit( # pylint: disable=W0212
830
- updates=self._updates,
831
- requirements=self._requirements,
832
- )
+ if len(self._updates) > 0:
+ self._requirements += (AssertCreate(),)
+ self._table._do_commit( # pylint: disable=W0212
+ updates=self._updates,
+ requirements=self._requirements,
833
+ )
834
+
835
+ self._updates = ()
836
+ self._requirements = ()
837
838
return self._table
839
840
0 commit comments