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

tests: fix tests.archive.ArchiveTest.test_archive_pg_receivexlog_partial_handling

Browse Source
This commit is contained in:
Grigory Smolkin
2020-06-21 22:11:43 +03:00
parent 3df12374be
commit c8acde3f54
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/archive.py
+8 -9
View File
@@ -1919,7 +1919,8 @@ class ArchiveTest(ProbackupTest, unittest.TestCase):
node = self.make_simple_node( node = self.make_simple_node(
base_dir=os.path.join(module_name, fname, 'node'), base_dir=os.path.join(module_name, fname, 'node'),
set_replication=True, set_replication=True,
initdb_params=['--data-checksums']) initdb_params=['--data-checksums'],
pg_options={'archive_timeout': '10s'})
self.init_pb(backup_dir) self.init_pb(backup_dir)
self.add_instance(backup_dir, 'node', node) self.add_instance(backup_dir, 'node', node)
@@ -1942,9 +1943,6 @@ class ArchiveTest(ProbackupTest, unittest.TestCase):
replica.slow_start(replica=True) replica.slow_start(replica=True)
# FULL
self.backup_node(backup_dir, 'replica', replica, options=['--stream'])
if self.get_version(replica) < 100000: if self.get_version(replica) < 100000:
pg_receivexlog_path = self.get_bin_path('pg_receivexlog') pg_receivexlog_path = self.get_bin_path('pg_receivexlog')
else: else:
@@ -1965,9 +1963,8 @@ class ArchiveTest(ProbackupTest, unittest.TestCase):
'Failed to start pg_receivexlog: {0}'.format( 'Failed to start pg_receivexlog: {0}'.format(
pg_receivexlog.communicate()[1])) pg_receivexlog.communicate()[1]))
replica.safe_psql( # FULL
'postgres', self.backup_node(backup_dir, 'replica', replica, options=['--stream'])
'CHECKPOINT')
node.safe_psql( node.safe_psql(
"postgres", "postgres",
@@ -1976,7 +1973,8 @@ class ArchiveTest(ProbackupTest, unittest.TestCase):
"from generate_series(0,1000000) i") "from generate_series(0,1000000) i")
# PAGE # PAGE
self.backup_node(backup_dir, 'replica', replica, backup_type='page') self.backup_node(
backup_dir, 'replica', replica, backup_type='delta', options=['--stream'])
node.safe_psql( node.safe_psql(
"postgres", "postgres",
@@ -2013,7 +2011,8 @@ class ArchiveTest(ProbackupTest, unittest.TestCase):
# Clean after yourself # Clean after yourself
pg_receivexlog.kill() pg_receivexlog.kill()
self.del_test_dir(module_name, fname) self.del_test_dir(
module_name, fname, [node, replica, node_restored])
@unittest.skip("skip") @unittest.skip("skip")
def test_multi_timeline_recovery_prefetching(self): def test_multi_timeline_recovery_prefetching(self):