Fix some flaky tests (#6587)

Fix for some simple flakiness'.
All `DROP USER' and cleanup function calls.

src/test/regress/expected/background_rebalance.out

@@ -120,7 +120,7 @@ SELECT pg_sleep(1);
 
 -- failing move due to a stopped rebalance, first clean orphans to make the error stable
 SET client_min_messages TO WARNING;
-CALL citus_cleanup_orphaned_shards();
+CALL citus_cleanup_orphaned_resources();
 RESET client_min_messages;
 SELECT citus_move_shard_placement(85674000, 'localhost', :worker_1_port, 'localhost', :worker_2_port, shard_transfer_mode => 'block_writes');
 WARNING:  shard is already present on node localhost:xxxxx
@@ -212,3 +212,4 @@ SELECT citus_rebalance_stop();
 RESET ROLE;
 SET client_min_messages TO WARNING;
 DROP SCHEMA background_rebalance CASCADE;
+DROP USER non_super_user_rebalance;

src/test/regress/expected/cpu_priority.out

@@ -132,8 +132,12 @@ DETAIL:  on server postgres@localhost:xxxxx connectionId: xxxxxxx
 
 (1 row)
 
-CALL citus_cleanup_orphaned_shards();
+SELECT public.wait_for_resource_cleanup();
-NOTICE:  cleaned up 4 orphaned shards
+ wait_for_resource_cleanup
+---------------------------------------------------------------------
+
+(1 row)
+
 -- Make sure shard splits use citus.cpu_priority_for_logical_replication_senders
 -- in their CREATE SUBSCRIPTION commands.
 SELECT pg_catalog.citus_split_shard_by_split_points(

src/test/regress/expected/single_node_enterprise.out

@@ -487,11 +487,14 @@ SET search_path TO single_node_ent;
 -- Cleanup
 RESET citus.log_remote_commands;
 SET client_min_messages TO WARNING;
+CALL pg_catalog.citus_cleanup_orphaned_resources();
 DROP SCHEMA single_node_ent CASCADE;
 DROP OWNED BY full_access_single_node;
 DROP OWNED BY read_access_single_node;
+DROP OWNED BY no_access_single_node;
 DROP ROLE full_access_single_node;
 DROP ROLE read_access_single_node;
+DROP ROLE no_access_single_node;
 -- remove the nodes for next tests
 SELECT 1 FROM master_remove_node('localhost', :master_port);
  ?column?

src/test/regress/sql/background_rebalance.sql

@@ -43,7 +43,7 @@ SELECT pg_sleep(1);
 
 -- failing move due to a stopped rebalance, first clean orphans to make the error stable
 SET client_min_messages TO WARNING;
-CALL citus_cleanup_orphaned_shards();
+CALL citus_cleanup_orphaned_resources();
 RESET client_min_messages;
 SELECT citus_move_shard_placement(85674000, 'localhost', :worker_1_port, 'localhost', :worker_2_port, shard_transfer_mode => 'block_writes');
 
@@ -80,3 +80,4 @@ RESET ROLE;
 
 SET client_min_messages TO WARNING;
 DROP SCHEMA background_rebalance CASCADE;
+DROP USER non_super_user_rebalance;

src/test/regress/sql/cpu_priority.sql

@@ -71,7 +71,7 @@ SET citus.cpu_priority_for_logical_replication_senders = 15;
 SELECT master_move_shard_placement(11568900, 'localhost', :worker_2_port, 'localhost', :worker_1_port, 'force_logical');
 SET citus.max_high_priority_background_processes = 3;
 SELECT master_move_shard_placement(11568900, 'localhost', :worker_1_port, 'localhost', :worker_2_port, 'force_logical');
-CALL citus_cleanup_orphaned_shards();
+SELECT public.wait_for_resource_cleanup();
 
 -- Make sure shard splits use citus.cpu_priority_for_logical_replication_senders
 -- in their CREATE SUBSCRIPTION commands.

src/test/regress/sql/single_node_enterprise.sql

@@ -310,12 +310,15 @@ SET search_path TO single_node_ent;
 -- Cleanup
 RESET citus.log_remote_commands;
 SET client_min_messages TO WARNING;
+CALL pg_catalog.citus_cleanup_orphaned_resources();
 DROP SCHEMA single_node_ent CASCADE;
 
 DROP OWNED BY full_access_single_node;
 DROP OWNED BY read_access_single_node;
+DROP OWNED BY no_access_single_node;
 DROP ROLE full_access_single_node;
 DROP ROLE read_access_single_node;
+DROP ROLE no_access_single_node;
 
 -- remove the nodes for next tests
 SELECT 1 FROM master_remove_node('localhost', :master_port);