Merge pull request #535 from postgrespro/REL_2_5-PBCKP-277

[PBCKP-277] stabilize catchup.CatchupTest.test_config_exclusion

Author: avaness

.travis.yml

@@ -27,7 +27,6 @@ notifications:
 # Default MODE is basic, i.e. all tests with PG_PROBACKUP_TEST_BASIC=ON
 env:
     - PG_VERSION=15 PG_BRANCH=master PTRACK_PATCH_PG_BRANCH=master
-    - PG_VERSION=15 PG_BRANCH=REL_15_STABLE PTRACK_PATCH_PG_BRANCH=REL_15_STABLE
     - PG_VERSION=14 PG_BRANCH=REL_14_STABLE PTRACK_PATCH_PG_BRANCH=REL_14_STABLE
     - PG_VERSION=13 PG_BRANCH=REL_13_STABLE PTRACK_PATCH_PG_BRANCH=REL_13_STABLE
     - PG_VERSION=12 PG_BRANCH=REL_12_STABLE PTRACK_PATCH_PG_BRANCH=REL_12_STABLE

tests/catchup.py

@@ -1362,6 +1362,7 @@ def test_config_exclusion(self):
         dst_options = {}
         dst_options['port'] = str(dst_pg.port)
         self.set_auto_conf(dst_pg, dst_options)
+        dst_pg._assign_master(src_pg)
         dst_pg.slow_start(replica = True)
         dst_pg.stop()
 
@@ -1390,6 +1391,7 @@ def test_config_exclusion(self):
         # check: run verification query
         src_pg.safe_psql("postgres", "INSERT INTO ultimate_question VALUES(42)")
         src_query_result = src_pg.safe_psql("postgres", "SELECT * FROM ultimate_question")
+        dst_pg.catchup() # wait for replication
         dst_query_result = dst_pg.safe_psql("postgres", "SELECT * FROM ultimate_question")
         self.assertEqual(src_query_result, dst_query_result, 'Different answer from copy')
 
@@ -1419,6 +1421,7 @@ def test_config_exclusion(self):
         # check: run verification query
         src_pg.safe_psql("postgres", "INSERT INTO ultimate_question VALUES(2*42)")
         src_query_result = src_pg.safe_psql("postgres", "SELECT * FROM ultimate_question")
+        dst_pg.catchup() # wait for replication
         dst_query_result = dst_pg.safe_psql("postgres", "SELECT * FROM ultimate_question")
         self.assertEqual(src_query_result, dst_query_result, 'Different answer from copy')
 
@@ -1447,6 +1450,7 @@ def test_config_exclusion(self):
         # check: run verification query
         src_pg.safe_psql("postgres", "INSERT INTO ultimate_question VALUES(3*42)")
         src_query_result = src_pg.safe_psql("postgres", "SELECT * FROM ultimate_question")
+        dst_pg.catchup() # wait for replication
         dst_query_result = dst_pg.safe_psql("postgres", "SELECT * FROM ultimate_question")
         self.assertEqual(src_query_result, dst_query_result, 'Different answer from copy')