Try running cleanup function more than once

src/test/regress/expected/citus_non_blocking_split_shard_cleanup.out

@@ -113,6 +113,18 @@ SELECT public.wait_for_resource_cleanup();
 
 (1 row)
 
+SELECT public.wait_for_resource_cleanup();
+ wait_for_resource_cleanup
+---------------------------------------------------------------------
+
+(1 row)
+
+SELECT public.wait_for_resource_cleanup();
+ wait_for_resource_cleanup
+---------------------------------------------------------------------
+
+(1 row)
+
 \c - - - :worker_2_port
 SET search_path TO "citus_split_test_schema";
 -- Replication slots should be cleaned up

src/test/regress/expected/logical_replication.out

@@ -93,6 +93,18 @@ SELECT public.wait_for_resource_cleanup();
 
 (1 row)
 
+SELECT public.wait_for_resource_cleanup();
+ wait_for_resource_cleanup
+---------------------------------------------------------------------
+
+(1 row)
+
+SELECT public.wait_for_resource_cleanup();
+ wait_for_resource_cleanup
+---------------------------------------------------------------------
+
+(1 row)
+
 -- the subscription is still there, as there is no cleanup record for it
 -- we have created it manually
 SELECT subname from pg_subscription;

src/test/regress/sql/citus_non_blocking_split_shard_cleanup.sql

@@ -80,6 +80,8 @@ SELECT pg_catalog.citus_split_shard_by_split_points(
     'force_logical');
 
 SELECT public.wait_for_resource_cleanup();
+SELECT public.wait_for_resource_cleanup();
+SELECT public.wait_for_resource_cleanup();
 
 \c - - - :worker_2_port
 SET search_path TO "citus_split_test_schema";

src/test/regress/sql/logical_replication.sql

@@ -53,6 +53,8 @@ SET search_path TO logical_replication;
 
 select citus_move_shard_placement(6830002, 'localhost', :worker_1_port, 'localhost', :worker_2_port, 'force_logical');
 
+SELECT public.wait_for_resource_cleanup();
+SELECT public.wait_for_resource_cleanup();
 SELECT public.wait_for_resource_cleanup();
 
 -- the subscription is still there, as there is no cleanup record for it