@@ -652,6 +652,42 @@ def test_update_metadata_add_snapshot(table_v2: Table) -> None:
652
652
assert new_metadata .last_updated_ms == new_snapshot .timestamp_ms
653
653
654
654
655
+ def test_update_metadata_rollback_to_snapshot (table_v2 : Table ) -> None :
656
+ assert table_v2 .rollback_to_snapshot (snapshot_id = 3051729675574597004 ) == Snapshot (
657
+ snapshot_id = 3051729675574597004 ,
658
+ parent_snapshot_id = None ,
659
+ sequence_number = 0 ,
660
+ timestamp_ms = 1515100955770 ,
661
+ manifest_list = 's3://a/b/1.avro' ,
662
+ summary = Summary (Operation .APPEND ),
663
+ schema_id = None ,
664
+ )
665
+
666
+
667
+ def test_update_metadata_rollback_to_timestamp (table_v2 : Table ) -> None :
668
+ assert table_v2 .rollback_to_timestamp (timestamp = 1555100955771 ) == Snapshot (
669
+ snapshot_id = 3055729675574597004 ,
670
+ parent_snapshot_id = 3051729675574597004 ,
671
+ sequence_number = 1 ,
672
+ timestamp_ms = 1555100955770 ,
673
+ manifest_list = 's3://a/b/2.avro' ,
674
+ summary = Summary (Operation .APPEND ),
675
+ schema_id = 1 ,
676
+ )
677
+
678
+
679
+ def test_update_metadata_set_current_snapshot (table_v2 : Table ) -> None :
680
+ assert table_v2 .set_current_snapshot (snapshot_id = 3051729675574597004 ) == Snapshot (
681
+ snapshot_id = 3051729675574597004 ,
682
+ parent_snapshot_id = None ,
683
+ sequence_number = 0 ,
684
+ timestamp_ms = 1515100955770 ,
685
+ manifest_list = 's3://a/b/1.avro' ,
686
+ summary = Summary (Operation .APPEND ),
687
+ schema_id = None ,
688
+ )
689
+
690
+
655
691
def test_update_metadata_set_snapshot_ref (table_v2 : Table ) -> None :
656
692
update = SetSnapshotRefUpdate (
657
693
ref_name = "main" ,
0 commit comments