tests: minor fixes

Author: gsmolk

tests/option_test.py

@@ -127,10 +127,11 @@ def test_options_5(self):
             self.init_pb(backup_dir))
         self.add_instance(backup_dir, 'node', node)
 
-        node.start()
+        node.slow_start()
 
         # syntax error in pg_probackup.conf
-        with open(os.path.join(backup_dir, "backups", "node", "pg_probackup.conf"), "a") as conf:
+        conf_file = os.path.join(backup_dir, "backups", "node", "pg_probackup.conf")
+        with open(conf_file, "a") as conf:
             conf.write(" = INFINITE\n")
         try:
             self.backup_node(backup_dir, 'node', node)
@@ -139,15 +140,15 @@ def test_options_5(self):
                 repr(self.output), self.cmd))
         except ProbackupException as e:
             self.assertEqual(e.message,
-                'ERROR: syntax error in " = INFINITE"\n',
+                'ERROR: Syntax error in " = INFINITE"\n',
                 '\n Unexpected Error Message: {0}\n CMD: {1}'.format(repr(e.message), self.cmd))
 
         self.clean_pb(backup_dir)
         self.init_pb(backup_dir)
         self.add_instance(backup_dir, 'node', node)
 
         # invalid value in pg_probackup.conf
-        with open(os.path.join(backup_dir, "backups", "node", "pg_probackup.conf"), "a") as conf:
+        with open(conf_file, "a") as conf:
             conf.write("BACKUP_MODE=\n")
 
         try:
@@ -157,15 +158,15 @@ def test_options_5(self):
                 repr(self.output), self.cmd))
         except ProbackupException as e:
             self.assertEqual(e.message,
-                'ERROR: invalid backup-mode ""\n',
+                'ERROR: Invalid option "BACKUP_MODE" in file "{0}"\n'.format(conf_file),
                 '\n Unexpected Error Message: {0}\n CMD: {1}'.format(repr(e.message), self.cmd))
 
         self.clean_pb(backup_dir)
         self.init_pb(backup_dir)
         self.add_instance(backup_dir, 'node', node)
 
         # Command line parameters should override file values
-        with open(os.path.join(backup_dir, "backups", "node", "pg_probackup.conf"), "a") as conf:
+        with open(conf_file, "a") as conf:
             conf.write("retention-redundancy=1\n")
 
         self.assertEqual(self.show_config(backup_dir, 'node')['retention-redundancy'], '1')
@@ -178,11 +179,11 @@ def test_options_5(self):
                 repr(self.output), self.cmd))
         except ProbackupException as e:
             self.assertEqual(e.message,
-                'ERROR: option system-identifier cannot be specified in command line\n',
+                'ERROR: Option system-identifier cannot be specified in command line\n',
                 '\n Unexpected Error Message: {0}\n CMD: {1}'.format(repr(e.message), self.cmd))
 
         # invalid value in pg_probackup.conf
-        with open(os.path.join(backup_dir, "backups", "node", "pg_probackup.conf"), "a") as conf:
+        with open(conf_file, "a") as conf:
             conf.write("SMOOTH_CHECKPOINT=FOO\n")
 
         try:
@@ -192,16 +193,15 @@ def test_options_5(self):
                 repr(self.output), self.cmd))
         except ProbackupException as e:
             self.assertEqual(e.message,
-                "ERROR: option -C, --smooth-checkpoint should be a boolean: 'FOO'\n",
+                'ERROR: Invalid option "SMOOTH_CHECKPOINT" in file "{0}"\n'.format(conf_file),
                 '\n Unexpected Error Message: {0}\n CMD: {1}'.format(repr(e.message), self.cmd))
 
         self.clean_pb(backup_dir)
         self.init_pb(backup_dir)
         self.add_instance(backup_dir, 'node', node)
 
         # invalid option in pg_probackup.conf
-        pbconf_path = os.path.join(backup_dir, "backups", "node", "pg_probackup.conf")
-        with open(pbconf_path, "a") as conf:
+        with open(conf_file, "a") as conf:
             conf.write("TIMELINEID=1\n")
 
         try:
@@ -211,7 +211,7 @@ def test_options_5(self):
                 repr(self.output), self.cmd))
         except ProbackupException as e:
             self.assertEqual(e.message,
-                'ERROR: invalid option "TIMELINEID" in file "{0}"\n'.format(pbconf_path),
+                'ERROR: Invalid option "TIMELINEID" in file "{0}"\n'.format(conf_file),
                 '\n Unexpected Error Message: {0}\n CMD: {1}'.format(repr(e.message), self.cmd))
 
         # Clean after yourself

tests/ptrack_clean.py

@@ -130,7 +130,9 @@ def test_ptrack_clean_replica(self):
             pg_options={
                 'ptrack_enable': 'on',
                 'wal_level': 'replica',
-                'max_wal_senders': '2'})
+                'max_wal_senders': '2',
+                'archive_timeout': '30s'})
+
         backup_dir = os.path.join(self.tmp_path, module_name, fname, 'backup')
         self.init_pb(backup_dir)
         self.add_instance(backup_dir, 'master', master)
@@ -237,7 +239,8 @@ def test_ptrack_clean_replica(self):
             options=[
                 '-j10', '--master-host=localhost',
                 '--master-db=postgres',
-                '--master-port={0}'.format(master.port)])
+                '--master-port={0}'.format(master.port),
+                '--stream'])
         master.safe_psql('postgres', 'checkpoint')
 
         for i in idx_ptrack:

tests/ptrack_empty.py

@@ -9,9 +9,9 @@
 
 class SimpleTest(ProbackupTest, unittest.TestCase):
 
-    # @unittest.skip("skip")
+    @unittest.skip("skip")
     # @unittest.expectedFailure
-    def test_ptrack_clean(self):
+    def test_ptrack_empty(self):
         """Take backups of every available types and check that PTRACK is clean"""
         fname = self.id().split('.')[3]
         node = self.make_simple_node(
@@ -87,9 +87,9 @@ def test_ptrack_clean(self):
         # Clean after yourself
         self.del_test_dir(module_name, fname)
 
-    # @unittest.skip("skip")
+    @unittest.skip("skip")
     # @unittest.expectedFailure
-    def test_ptrack_clean_replica(self):
+    def test_ptrack_empty_replica(self):
         """Take backups of every available types from master and check that PTRACK on replica is clean"""
         fname = self.id().split('.')[3]
         master = self.make_simple_node(

tests/ptrack_vacuum_full.py

@@ -99,9 +99,11 @@ def test_ptrack_vacuum_full_replica(self):
             set_replication=True,
             initdb_params=['--data-checksums'],
             pg_options={
-                'ptrack_enable': 'on', 'wal_level': 'replica',
-                'max_wal_senders': '2', 'autovacuum': 'off',
-                'checkpoint_timeout': '30s'}
+                'ptrack_enable': 'on',
+                'wal_level': 'replica',
+                'max_wal_senders': '2',
+                'autovacuum': 'off',
+                'archive_timeout': '30s'}
             )
         backup_dir = os.path.join(self.tmp_path, module_name, fname, 'backup')
         self.init_pb(backup_dir)
@@ -150,7 +152,8 @@ def test_ptrack_vacuum_full_replica(self):
                 '-j10',
                 '--master-host=localhost',
                 '--master-db=postgres',
-                '--master-port={0}'.format(master.port)
+                '--master-port={0}'.format(master.port),
+                '--stream'
                 ]
             )
         # TODO: check that all ptrack are nullified

tests/ptrack_vacuum_truncate.py

@@ -147,7 +147,8 @@ def test_ptrack_vacuum_truncate_replica(self):
                 '-j10',
                 '--master-host=localhost',
                 '--master-db=postgres',
-                '--master-port={0}'.format(master.port)
+                '--master-port={0}'.format(master.port),
+                '--stream'
                 ]
             )
 

tests/show_test.py

@@ -197,7 +197,9 @@ def test_corrupt_control_file(self):
         fd.write("statuss = OK")
         fd.close()
 
-        self.assertIn('invalid option "statuss" in file'.format(file), self.show_pb(backup_dir, 'node', as_text=True))
+        self.assertIn(
+            'WARNING: Invalid option "statuss" in file'.format(file),
+            self.show_pb(backup_dir, 'node', as_text=True))
 
         # Clean after yourself
-        self.del_test_dir(module_name, fname)
+        # self.del_test_dir(module_name, fname)

tests/validate_test.py

@@ -1519,10 +1519,17 @@ def test_pgpro561(self):
             backup_dir, 'node1', node1,
             backup_type='page', options=["--stream"])
         self.restore_node(backup_dir, 'node1', data_dir=node2.data_dir)
+
         node2.append_conf(
             'postgresql.auto.conf', 'port = {0}'.format(node2.port))
+        node2.append_conf(
+            'postgresql.auto.conf', 'archive_mode = off')
         node2.slow_start()
 
+        node2.append_conf(
+            'postgresql.auto.conf', 'archive_mode = on')
+        node2.restart()
+
         timeline_node1 = node1.get_control_data()["Latest checkpoint's TimeLineID"]
         timeline_node2 = node2.get_control_data()["Latest checkpoint's TimeLineID"]
         self.assertEqual(