aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/test/subscription/t/002_types.pl3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/test/subscription/t/002_types.pl b/src/test/subscription/t/002_types.pl
index ec55a5f884a..f5d3037ca92 100644
--- a/src/test/subscription/t/002_types.pl
+++ b/src/test/subscription/t/002_types.pl
@@ -561,7 +561,8 @@ e|{e,d}
# which needs an active snapshot in order to operate.
$node_publisher->safe_psql('postgres', "INSERT INTO tst_dom_constr VALUES (11)");
-$node_publisher->wait_for_catchup($appname);
+$node_publisher->poll_query_until('postgres', $caughtup_query)
+ or die "Timed out while waiting for subscriber to catch up";
$result =
$node_subscriber->safe_psql('postgres', "SELECT sum(a) FROM tst_dom_constr");