From 81dbdd3231f53d842a19a0d7ee63f8d6026e2160 Mon Sep 17 00:00:00 2001 From: naisila Date: Mon, 13 Nov 2023 10:50:58 +0300 Subject: [PATCH] Test whether flaky worker_split_text_copy_test --- .../expected/worker_split_text_copy_test.out | 24 +++++++++++++++++++ .../sql/worker_split_text_copy_test.sql | 4 ++++ 2 files changed, 28 insertions(+) diff --git a/src/test/regress/expected/worker_split_text_copy_test.out b/src/test/regress/expected/worker_split_text_copy_test.out index cddb6d85e..50733886f 100644 --- a/src/test/regress/expected/worker_split_text_copy_test.out +++ b/src/test/regress/expected/worker_split_text_copy_test.out @@ -226,3 +226,27 @@ SELECT COUNT(*) FROM worker_split_text_copy_test.shard_to_split_copy_81070016; SET client_min_messages TO WARNING; DROP SCHEMA worker_split_text_copy_test CASCADE; -- END: CLEANUP. +SELECT result FROM run_command_on_all_nodes($$SELECT count(*) FROM pg_replication_slots$$); + result +--------------------------------------------------------------------- + 0 + 0 + 0 +(3 rows) + +SELECT result FROM run_command_on_all_nodes($$SELECT count(*) FROM pg_publication$$); + result +--------------------------------------------------------------------- + 0 + 0 + 0 +(3 rows) + +SELECT result FROM run_command_on_all_nodes($$SELECT count(*) FROM pg_subscription$$); + result +--------------------------------------------------------------------- + 0 + 0 + 0 +(3 rows) + diff --git a/src/test/regress/sql/worker_split_text_copy_test.sql b/src/test/regress/sql/worker_split_text_copy_test.sql index fe2a614b3..2c618c8e1 100644 --- a/src/test/regress/sql/worker_split_text_copy_test.sql +++ b/src/test/regress/sql/worker_split_text_copy_test.sql @@ -203,3 +203,7 @@ SELECT COUNT(*) FROM worker_split_text_copy_test.shard_to_split_copy_81070016; SET client_min_messages TO WARNING; DROP SCHEMA worker_split_text_copy_test CASCADE; -- END: CLEANUP. + +SELECT result FROM run_command_on_all_nodes($$SELECT count(*) FROM pg_replication_slots$$); +SELECT result FROM run_command_on_all_nodes($$SELECT count(*) FROM pg_publication$$); +SELECT result FROM run_command_on_all_nodes($$SELECT count(*) FROM pg_subscription$$);