PBM-1057 check PITR on PSA infrastructure

Percona-QA · Aug 26, 2024 · 5b4a071 · 5b4a071
1 parent 015d0a5
commit 5b4a071
Show file tree

Hide file tree

Showing 2 changed files with 32 additions and 3 deletions.
diff --git a/pbm-functional/pytest/cluster.py b/pbm-functional/pytest/cluster.py
@@ -547,12 +547,13 @@ def enable_pitr(self,**kwargs):
         result = n.check_output(
             "pbm config --set pitr.enabled=true --set pitr.compression=none --out json " + pitr_extra_args)
         Cluster.log("Enabling PITR: " + result)
-        timeout = time.time() + 600
+        timeout = time.time() + 150
         while True:
             if self.check_pitr():
                 break
             if time.time() > timeout:
-                assert False
+                status=self.get_status()['pitr']
+                assert False, status
             time.sleep(1)
 
     # disables PITR
@@ -561,7 +562,7 @@ def disable_pitr(self):
         result = n.check_output(
             "pbm config --set pitr.enabled=false --out json")
         Cluster.log("Disabling PITR: " + result)
-        timeout = time.time() + 600
+        timeout = time.time() + 150
         while True:
             if not self.check_pitr():
                 break

diff --git a/pbm-functional/pytest/test_PBM-979.py b/pbm-functional/pytest/test_PBM-979.py
@@ -79,6 +79,34 @@ def test_logical_PBM_T233(start_cluster,cluster):
     assert pymongo.MongoClient(cluster.connection)["test"]["test"].count_documents({}) == len(documents)
     Cluster.log("Finished successfully")
 
+@pytest.mark.timeout(600,func_only=True)
+def test_logical_pitr_PBM_T263(start_cluster,cluster):
+    time.sleep(5) # wait for delayed node
+    cluster.check_pbm_status()
+    pymongo.MongoClient(cluster.connection)["test"]["test"].insert_many(documents)
+    backup=cluster.make_backup("logical")
+    #check if the backup was taken from the hidden node
+    logs=cluster.exec_pbm_cli("logs -n rs1/rs103:27017 -e backup -o json").stdout
+    assert backup in logs
+    Cluster.log("Logs from hidden node:\n" + logs)
+    cluster.enable_pitr(pitr_extra_args="--set pitr.oplogSpanMin=0.5")
+    pymongo.MongoClient(cluster.connection)["test"]["pitr"].insert_many(documents)
+    time.sleep(10)
+    pitr = datetime.utcnow().strftime("%Y-%m-%dT%H:%M:%S")
+    backup="--time=" + pitr
+    Cluster.log("Time for PITR is: " + pitr)
+    time.sleep(60)
+    cluster.disable_pitr()
+    time.sleep(10)
+    result=pymongo.MongoClient(cluster.connection)["test"]["test"].delete_many({})
+    result=pymongo.MongoClient(cluster.connection)["test"]["pitr"].delete_many({})
+    cluster.make_restore(backup)
+    time.sleep(5) # wait for delayed node
+    cluster.check_pbm_status()
+    assert pymongo.MongoClient(cluster.connection)["test"]["test"].count_documents({}) == len(documents)
+    assert pymongo.MongoClient(cluster.connection)["test"]["pitr"].count_documents({}) == len(documents)
+    Cluster.log("Finished successfully")
+
 @pytest.mark.timeout(300,func_only=True)
 def test_physical_PBM_T195(start_cluster,cluster):
     time.sleep(5) # wait for delayed node