You've already forked pg_probackup
mirror of
https://github.com/postgrespro/pg_probackup.git
synced 2025-07-17 07:22:20 +02:00
[Issue #120] fix tests.delete.DeleteTest.test_delete_error_backups
This commit is contained in:
@ -825,25 +825,51 @@ class DeleteTest(ProbackupTest, unittest.TestCase):
|
|||||||
# Take PAGE BACKUP
|
# Take PAGE BACKUP
|
||||||
backup_id_b = self.backup_node(backup_dir, 'node', node, backup_type="page")
|
backup_id_b = self.backup_node(backup_dir, 'node', node, backup_type="page")
|
||||||
|
|
||||||
|
backup_id_c = self.backup_node(backup_dir, 'node', node, backup_type="page")
|
||||||
|
|
||||||
|
backup_id_d = self.backup_node(backup_dir, 'node', node, backup_type="page")
|
||||||
|
|
||||||
|
# full backup mode
|
||||||
|
self.backup_node(backup_dir, 'node', node)
|
||||||
|
self.backup_node(backup_dir, 'node', node, backup_type="page")
|
||||||
|
backup_id_e = self.backup_node(backup_dir, 'node', node, backup_type="page")
|
||||||
|
self.backup_node(backup_dir, 'node', node, backup_type="page")
|
||||||
|
|
||||||
# Change status to ERROR
|
# Change status to ERROR
|
||||||
self.change_backup_status(backup_dir, 'node', backup_id_a, 'ERROR')
|
self.change_backup_status(backup_dir, 'node', backup_id_a, 'ERROR')
|
||||||
self.change_backup_status(backup_dir, 'node', backup_id_b, 'ERROR')
|
self.change_backup_status(backup_dir, 'node', backup_id_c, 'ERROR')
|
||||||
|
self.change_backup_status(backup_dir, 'node', backup_id_e, 'ERROR')
|
||||||
|
|
||||||
print(self.show_pb(backup_dir, as_text=True, as_json=False))
|
print(self.show_pb(backup_dir, as_text=True, as_json=False))
|
||||||
|
|
||||||
|
show_backups = self.show_pb(backup_dir, 'node')
|
||||||
|
self.assertEqual(len(show_backups), 10)
|
||||||
|
|
||||||
|
# delete error backups
|
||||||
|
output = self.delete_pb(backup_dir, 'node', options=['--status=ERROR', '--dry-run'])
|
||||||
|
show_backups = self.show_pb(backup_dir, 'node')
|
||||||
|
self.assertEqual(len(show_backups), 10)
|
||||||
|
|
||||||
|
self.assertIn(
|
||||||
|
"Deleting all backups with status 'ERROR' in dry run mode",
|
||||||
|
output)
|
||||||
|
|
||||||
|
self.assertIn(
|
||||||
|
"INFO: Backup {0} with status OK can be deleted".format(backup_id_d),
|
||||||
|
output)
|
||||||
|
|
||||||
|
print(self.show_pb(backup_dir, as_text=True, as_json=False))
|
||||||
|
|
||||||
|
show_backups = self.show_pb(backup_dir, 'node')
|
||||||
|
output = self.delete_pb(backup_dir, 'node', options=['--status=ERROR'])
|
||||||
|
print(output)
|
||||||
show_backups = self.show_pb(backup_dir, 'node')
|
show_backups = self.show_pb(backup_dir, 'node')
|
||||||
self.assertEqual(len(show_backups), 4)
|
self.assertEqual(len(show_backups), 4)
|
||||||
|
|
||||||
# delete error backups
|
|
||||||
self.delete_pb(backup_dir, 'node', options=['--status=ERROR'])
|
|
||||||
|
|
||||||
print(self.show_pb(backup_dir, as_text=True, as_json=False))
|
|
||||||
|
|
||||||
show_backups = self.show_pb(backup_dir, 'node')
|
|
||||||
self.assertEqual(len(show_backups), 2)
|
|
||||||
|
|
||||||
self.assertEqual(show_backups[0]['status'], "OK")
|
self.assertEqual(show_backups[0]['status'], "OK")
|
||||||
self.assertEqual(show_backups[1]['status'], "OK")
|
self.assertEqual(show_backups[1]['status'], "OK")
|
||||||
|
self.assertEqual(show_backups[2]['status'], "OK")
|
||||||
|
self.assertEqual(show_backups[3]['status'], "OK")
|
||||||
|
|
||||||
# Clean after yourself
|
# Clean after yourself
|
||||||
self.del_test_dir(module_name, fname)
|
self.del_test_dir(module_name, fname)
|
||||||
|
Reference in New Issue
Block a user