Try to get flaky result

.github/workflows/build_and_test.yml

@@ -486,7 +486,7 @@ jobs:
       image: ${{ needs.params.outputs.fail_test_image_name }}:${{ fromJson(needs.params.outputs.pg16_version).full }}${{ needs.params.outputs.image_suffix }}
       options: --user root
     env:
-      runs: 8
+      runs: 20
     needs:
     - params
     - build

src/test/regress/expected/citus_non_blocking_split_shard_cleanup.out

@@ -113,18 +113,8 @@ 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)
-
+-- try to get flaky result
+SET search_path TO "citus_split_test_schema";
 \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,18 +93,8 @@ 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)
-
+-- try to get flaky result
+SET search_path TO logical_replication;
 -- 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,8 +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();
+-- try to get flaky result
+SET search_path TO "citus_split_test_schema";
 
 \c - - - :worker_2_port
 SET search_path TO "citus_split_test_schema";

src/test/regress/sql/logical_replication.sql

@@ -54,8 +54,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();
+-- try to get flaky result
+SET search_path TO logical_replication;
 
 -- the subscription is still there, as there is no cleanup record for it
 -- we have created it manually