@@ -652,6 +652,42 @@ def test_update_metadata_add_snapshot(table_v2: Table) -> None:
652652 assert new_metadata .last_updated_ms == new_snapshot .timestamp_ms
653653
654654
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+
655691def test_update_metadata_set_snapshot_ref (table_v2 : Table ) -> None :
656692 update = SetSnapshotRefUpdate (
657693 ref_name = "main" ,
0 commit comments