We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e631ddf commit 740db96Copy full SHA for 740db96
pyiceberg/table/update/snapshot.py
@@ -255,7 +255,8 @@ def _commit(self) -> UpdatesAndRequirements:
255
manifest_list_file_path = location_provider.new_metadata_location(file_name)
256
257
# get current snapshot id and starting snapshot id, and validate that there are no conflicts
258
- if self._transaction._table.__class__.__name__ != "StagedTable":
+ from pyiceberg.table import StagedTable
259
+ if not isinstance(self._transaction._table, StagedTable):
260
starting_snapshot = self._transaction.table_metadata.current_snapshot()
261
current_snapshot = self._transaction._table.refresh().metadata.current_snapshot()
262
self._validate(starting_snapshot, current_snapshot)
0 commit comments