Skip to content

Commit a4cffd4

Browse files
committed
address comments from kevin
1 parent e2f97cd commit a4cffd4

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

pyiceberg/table/__init__.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1504,9 +1504,8 @@ def _check_uuid(current_metadata: TableMetadata, new_metadata: TableMetadata) ->
15041504
def _do_commit(self, updates: tuple[TableUpdate, ...], requirements: tuple[TableRequirement, ...]) -> None:
15051505
response = self.catalog.commit_table(self, requirements, updates)
15061506

1507-
# Check UUID to detect table replacement (matches Java's RESTTableOperations.updateCurrentMetadata)
1508-
if not isinstance(self, StagedTable):
1509-
self._check_uuid(self.metadata, response.metadata)
1507+
# Check UUID to detect table replacement
1508+
self._check_uuid(self.metadata, response.metadata)
15101509

15111510
# https://github.com/apache/iceberg/blob/f6faa58/core/src/main/java/org/apache/iceberg/CatalogUtil.java#L527
15121511
# delete old metadata if METADATA_DELETE_AFTER_COMMIT_ENABLED is set to true and uses

0 commit comments

Comments
 (0)