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 48a3853 commit dd54fceCopy full SHA for dd54fce
init.sql
@@ -268,8 +268,10 @@ CREATE FUNCTION eliminate_sub(subname name, drop_sub bool DEFAULT true)
268
DECLARE
269
sub_exists bool;
270
BEGIN
271
- EXECUTE format('SELECT count(*) > 0 FROM pg_subscription WHERE subname
272
- = %L', subname) INTO sub_exists;
+ RAISE DEBUG '[SHARDMAN %] eliminating sub %, drop_sub %',
+ shardman.my_id(), subname, drop_sub;
273
+ EXECUTE format('SELECT EXISTS (SELECT 1 FROM pg_subscription WHERE subname
274
+ = %L)', subname) INTO sub_exists;
275
IF sub_exists THEN
276
EXECUTE format('ALTER SUBSCRIPTION %I DISABLE', subname);
277
EXECUTE format('ALTER SUBSCRIPTION %I SET (slot_name = NONE)', subname);
0 commit comments