We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0055bd2 commit 29fe09cCopy full SHA for 29fe09c
src/test/subscription/t/030_origin.pl
@@ -195,7 +195,13 @@
195
"Refresh publication when the publisher has subscribed for the new table, but the subscriber-side wants origin = none"
196
);
197
198
-$node_A->wait_for_subscription_sync($node_B, $subname_AB2);
+# Ensure that relation has reached 'ready' state before we try to drop it
199
+my $synced_query =
200
+ "SELECT count(1) = 0 FROM pg_subscription_rel WHERE srsubstate NOT IN ('r');";
201
+$node_A->poll_query_until('postgres', $synced_query)
202
+ or die "Timed out while waiting for subscriber to synchronize data";
203
+
204
+$node_B->wait_for_catchup($subname_AB2);
205
206
# clear the operations done by this test
207
$node_A->safe_psql('postgres', "DROP TABLE tab_new");
0 commit comments