tests: fixes

Author: gsmolk

tests/delete.py

@@ -411,7 +411,6 @@ def test_delete_interleaved_incremental_chains(self):
         node.slow_start()
 
         # Take FULL BACKUPs
-
         backup_id_a = self.backup_node(backup_dir, 'node', node)
         backup_id_b = self.backup_node(backup_dir, 'node', node)
 

tests/helpers/ptrack_helpers.py

@@ -949,7 +949,8 @@ def show_pb(
 
     def show_archive(
             self, backup_dir, instance=None, options=[],
-            as_text=False, as_json=True, old_binary=False
+            as_text=False, as_json=True, old_binary=False,
+            tli=0
             ):
 
         cmd_list = [
@@ -973,6 +974,23 @@ def show_archive(
                 data = self.run_pb(cmd_list + options, old_binary=old_binary)
             else:
                 data = json.loads(self.run_pb(cmd_list + options, old_binary=old_binary))
+
+            if instance:
+                instance_timelines = None
+                for instance_name in data:
+                    if instance_name['instance'] == instance:
+                        instance_timelines = instance_name['timelines']
+                        break
+
+                if tli > 0:
+                    timeline_data = None
+                    for timeline in instance_timelines:
+                        if timeline['tli'] == tli:
+                            return timeline
+
+                if instance_timelines:
+                    return instance_timelines
+
             return data
         else:
             show_splitted = self.run_pb(

tests/retention.py

@@ -25,10 +25,8 @@ def test_retention_redundancy_1(self):
         self.set_archiving(backup_dir, 'node', node)
         node.slow_start()
 
-        with open(os.path.join(
-                backup_dir, 'backups', 'node',
-                "pg_probackup.conf"), "a") as conf:
-            conf.write("retention-redundancy = 1\n")
+        self.set_config(
+            backup_dir, 'node', options=['--retention-redundancy=1'])
 
         # Make backups to be purged
         self.backup_node(backup_dir, 'node', node)
@@ -39,31 +37,31 @@ def test_retention_redundancy_1(self):
 
         self.assertEqual(len(self.show_pb(backup_dir, 'node')), 4)
 
+        output_before = self.show_archive(backup_dir, 'node', tli=1)
+
         # Purge backups
         log = self.delete_expired(
             backup_dir, 'node', options=['--expired', '--wal'])
         self.assertEqual(len(self.show_pb(backup_dir, 'node')), 2)
 
-        # Check that WAL segments were deleted
-        min_wal = None
-        max_wal = None
-        for line in log.splitlines():
-            if line.startswith("INFO: removed min WAL segment"):
-                min_wal = line[31:-1]
-            elif line.startswith("INFO: removed max WAL segment"):
-                max_wal = line[31:-1]
+        output_after = self.show_archive(backup_dir, 'node', tli=1)
 
-        if not min_wal:
-            self.assertTrue(False, "min_wal is empty")
+        self.assertEqual(
+            output_before['max-segno'],
+            output_after['max-segno'])
 
-        if not max_wal:
-            self.assertTrue(False, "max_wal is not set")
+        self.assertNotEqual(
+            output_before['min-segno'],
+            output_after['min-segno'])
+
+        # Check that WAL segments were deleted
+        min_wal = output_after['min-segno']
+        max_wal = output_after['max-segno']
 
         for wal_name in os.listdir(os.path.join(backup_dir, 'wal', 'node')):
             if not wal_name.endswith(".backup"):
-                # wal_name_b = wal_name.encode('ascii')
-                self.assertEqual(wal_name[8:] > min_wal[8:], True)
-                self.assertEqual(wal_name[8:] > max_wal[8:], True)
+                self.assertTrue(wal_name[8:] >= min_wal)
+                self.assertTrue(wal_name[8:] <= max_wal)
 
         # Clean after yourself
         self.del_test_dir(module_name, fname)
@@ -1353,7 +1351,7 @@ def test_window_error_backups_2(self):
 
         gdb.set_breakpoint('pg_stop_backup')
         gdb.run_until_break()
-        gdb._execute('signal SIGTERM')
+        gdb._execute('signal SIGKILL')
         gdb.continue_execution_until_error()
 
         page_id = self.show_pb(backup_dir, 'node')[1]['id']