Skip to content

Commit ecf2f70

Browse files
committed
test fix
1 parent 38c1afe commit ecf2f70

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
@@ -437,7 +437,9 @@ def _(update: AddSnapshotUpdate, base_metadata: TableMetadata, context: _TableMe
437437
"last_sequence_number": update.snapshot.sequence_number,
438438
"snapshots": base_metadata.snapshots + [update.snapshot],
439439
"next_row_id": base_metadata.next_row_id + update.snapshot.added_rows
440-
if base_metadata.next_row_id is not None and update.snapshot.added_rows is not None
440+
if base_metadata.format_version >= 3
441+
and base_metadata.next_row_id is not None
442+
and update.snapshot.added_rows is not None
441443
else None,
442444
}
443445
)

0 commit comments

Comments
 (0)