Skip to content

Commit 8f8af3e

Browse files
committed
test fix
1 parent 54ef773 commit 8f8af3e

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

pyiceberg/table/update/__init__.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -456,7 +456,9 @@ def _(update: AddSnapshotUpdate, base_metadata: TableMetadata, context: _TableMe
456456
"last_sequence_number": update.snapshot.sequence_number,
457457
"snapshots": base_metadata.snapshots + [update.snapshot],
458458
"next_row_id": base_metadata.next_row_id + update.snapshot.added_rows
459-
if base_metadata.next_row_id is not None and update.snapshot.added_rows is not None
459+
if base_metadata.format_version >= 3
460+
and base_metadata.next_row_id is not None
461+
and update.snapshot.added_rows is not None
460462
else None,
461463
}
462464
)

0 commit comments

Comments
 (0)