8000
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 8756930 commit 0324651Copy full SHA for 0324651
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