db/pg_probackup
1
0
Fork 0
mirror of https://github.com/postgrespro/pg_probackup.git synced 2026-06-21 01:34:15 +02:00
Code Issues Releases Activity

[PBCKP-434] fix replica_test.py

Browse Source 
There are a lot less messages to check for.
And in fact backup in test_archive_replica_not_null_offset starts to
succeed.
This commit is contained in:
Yura Sokolov
2022-12-25 21:33:43 +03:00
parent 82d2941347
commit 7d12d5fb39
1 changed files with 17 additions and 61 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/replica_test.py
+17 -61
View File
@@ -610,25 +610,9 @@ class ReplicaTest(ProbackupTest, unittest.TestCase):
'--stream'],
return_id=False)
self.assertIn(
'LOG: Invalid offset in stop_lsn value 0/4000000',
output)
self.assertIn(
'WARNING: WAL segment 000000010000000000000004 could not be streamed in 30 seconds',
output)
self.assertIn(
'WARNING: Failed to get next WAL record after 0/4000000, looking for previous WAL record',
output)
self.assertIn(
'LOG: Looking for LSN 0/4000000 in segment: 000000010000000000000003',
output)
self.assertIn(
'has endpoint 0/4000000 which is '
'equal or greater than requested LSN 0/4000000',
'equal or greater than requested LSN',
output)
self.assertIn(
@@ -715,19 +699,16 @@ class ReplicaTest(ProbackupTest, unittest.TestCase):
log_content = f.read()
self.assertIn(
'LOG: Invalid offset in stop_lsn value 0/4000000',
'has endpoint 0/4000000 which is '
'equal or greater than requested LSN',
log_content)
self.assertIn(
'LOG: Looking for segment: 000000010000000000000004',
'LOG: Found prior LSN:',
log_content)
self.assertIn(
'LOG: First record in WAL segment "000000010000000000000004": 0/4000028',
log_content)
self.assertIn(
'INFO: stop_lsn: 0/4000000',
'INFO: backup->stop_lsn 0/4000000',
log_content)
self.assertTrue(self.show_pb(backup_dir, 'replica')[0]['status'] == 'DONE')
@@ -782,18 +763,6 @@ class ReplicaTest(ProbackupTest, unittest.TestCase):
'--no-validate'],
return_id=False)
self.assertIn(
'LOG: Invalid offset in stop_lsn value 0/4000000',
output)
self.assertIn(
'WARNING: WAL segment 000000010000000000000004 could not be archived in 30 seconds',
output)
self.assertIn(
'WARNING: Failed to get next WAL record after 0/4000000, looking for previous WAL record',
output)
self.assertIn(
'LOG: Looking for LSN 0/4000000 in segment: 000000010000000000000003',
output)
@@ -807,8 +776,6 @@ class ReplicaTest(ProbackupTest, unittest.TestCase):
'LOG: Found prior LSN:',
output)
print(output)
# @unittest.skip("skip")
def test_archive_replica_not_null_offset(self):
"""
@@ -849,29 +816,22 @@ class ReplicaTest(ProbackupTest, unittest.TestCase):
'--no-validate'],
return_id=False)
with self.assertRaises(ProbackupException) as ctx:
self.backup_node(
backup_dir, 'node', replica, replica.data_dir,
options=[
'--archive-timeout=10',
'--log-level-console=LOG',
'--no-validate'])
e = ctx.exception
# vanilla -- 0/4000060
# pgproee -- 0/4000078
output = self.backup_node(
backup_dir, 'node', replica, replica.data_dir,
options=[
'--archive-timeout=10',
'--log-level-console=LOG',
'--no-validate'],
return_id=False)
self.assertRegex(
e.message,
r'LOG: Looking for LSN (0/4000060|0/4000078|0/4000070) in segment: 000000010000000000000004',
output,
r'LOG: Record \S+ has endpoint 0/4000000 which is equal.*0/4000000',
"\n CMD: {0}".format(self.cmd))
self.assertRegex(
e.message,
r'INFO: Wait for LSN (0/4000060|0/4000078|0/4000070) in archived WAL segment',
"\n CMD: {0}".format(self.cmd))
self.assertRegex(
e.message,
r'ERROR: WAL segment 000000010000000000000004 could not be archived in \d+ seconds',
output,
r'INFO: Backup \w+ completed\s*\Z',
"\n CMD: {0}".format(self.cmd))
# @unittest.skip("skip")
@@ -942,10 +902,6 @@ class ReplicaTest(ProbackupTest, unittest.TestCase):
pgdata = self.pgdata_content(replica.data_dir)
self.assertIn(
'WARNING: Could not read WAL record at',
output)
self.assertIn(
'LOG: Found prior LSN:',
output)