Skip to content

Commit ecb82b8

Browse files
committed
test fix
1 parent 232a436 commit ecb82b8

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
@@ -453,7 +453,9 @@ def _(update: AddSnapshotUpdate, base_metadata: TableMetadata, context: _TableMe
453453
"last_sequence_number": update.snapshot.sequence_number,
454454
"snapshots": base_metadata.snapshots + [update.snapshot],
455455
"next_row_id": base_metadata.next_row_id + update.snapshot.added_rows
456-
if base_metadata.next_row_id is not None and update.snapshot.added_rows is not None
456+
if base_metadata.format_version >= 3
457+
and base_metadata.next_row_id is not None
458+
and update.snapshot.added_rows is not None
457459
else None,
458460
}
459461
)

0 commit comments

Comments
 (0)