@@ -511,6 +511,7 @@ def commit_transaction(self) -> Table:
511
511
The table with the updates applied.
512
512
"""
513
513
if len (self ._updates ) > 0 :
514
+ self ._requirements += (AssertTableUUID (uuid = self .table_metadata .table_uuid ),)
514
515
self ._table ._do_commit ( # pylint: disable=W0212
515
516
updates = self ._updates ,
516
517
requirements = self ._requirements ,
@@ -565,7 +566,11 @@ def commit_transaction(self) -> Table:
565
566
The table with the updates applied.
566
567
"""
567
568
self ._requirements = (AssertCreate (),)
568
- return super ().commit_transaction ()
569
+ self ._table ._do_commit ( # pylint: disable=W0212
570
+ updates = self ._updates ,
571
+ requirements = self ._requirements ,
572
+ )
573
+ return self ._table
569
574
570
575
571
576
class AssignUUIDUpdate (IcebergBaseModel ):
@@ -2919,10 +2924,7 @@ def _commit(self) -> UpdatesAndRequirements:
2919
2924
snapshot_id = self ._snapshot_id , parent_snapshot_id = self ._parent_snapshot_id , ref_name = "main" , type = "branch"
2920
2925
),
2921
2926
),
2922
- (
2923
- AssertTableUUID (uuid = self ._transaction .table_metadata .table_uuid ),
2924
- AssertRefSnapshotId (snapshot_id = self ._parent_snapshot_id , ref = "main" ),
2925
- ),
2927
+ (AssertRefSnapshotId (snapshot_id = self ._parent_snapshot_id , ref = "main" ),),
2926
2928
)
2927
2929
2928
2930
0 commit comments