Skip to content

Commit ef9b84f

Browse files
committed
fix: Update the snapshot_id for _RewriteFiles._deleted_entries to mark them with the new snapshot id
1 parent a91dfb4 commit ef9b84f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pyiceberg/table/update/snapshot.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -693,7 +693,7 @@ def _get_entries(manifest: ManifestFile) -> list[ManifestEntry]:
693693
return [
694694
ManifestEntry.from_args(
695695
status=ManifestEntryStatus.DELETED,
696-
snapshot_id=entry.snapshot_id,
696+
snapshot_id=self.snapshot_id,
697697
sequence_number=entry.sequence_number,
698698
file_sequence_number=entry.file_sequence_number,
699699
data_file=entry.data_file,

0 commit comments

Comments
 (0)