diff --git a/src/test/regress/expected/create_drop_database_propagation.out b/src/test/regress/expected/create_drop_database_propagation.out
index e05616a42..9f98c740c 100644
--- a/src/test/regress/expected/create_drop_database_propagation.out
+++ b/src/test/regress/expected/create_drop_database_propagation.out
@@ -63,10 +63,10 @@ SELECT result from run_command_on_all_nodes(
 (3 rows)
 
 -- test database syncing after node addition
-select citus_remove_node('localhost', :worker_2_port);
- citus_remove_node
+select 1 from citus_remove_node('localhost', :worker_2_port);
+ ?column?
 ---------------------------------------------------------------------
-
+        1
 (1 row)
 
 --test with is_template true and allow connections false
@@ -100,10 +100,10 @@ SELECT result from run_command_on_all_nodes(
  [{"datacl": null, "datname": "mydatabase", "datctype": "C", "encoding": "UTF8", "datcollate": "C", "tablespace": "create_drop_db_tablespace", "datallowconn": false, "datconnlimit": 10, "datistemplate": false, "database_owner": "create_drop_db_test_user"}]
 (2 rows)
 
-select citus_add_node('localhost', :worker_2_port);
- citus_add_node
+select 1 from citus_add_node('localhost', :worker_2_port);
+ ?column?
 ---------------------------------------------------------------------
-             30
+        1
 (1 row)
 
 SELECT result from run_command_on_all_nodes(
diff --git a/src/test/regress/expected/pg15.out b/src/test/regress/expected/pg15.out
index 3ee5a15cf..e58387551 100644
--- a/src/test/regress/expected/pg15.out
+++ b/src/test/regress/expected/pg15.out
@@ -1611,10 +1611,10 @@ SELECT result from run_command_on_all_nodes(
 
 (3 rows)
 
-select citus_remove_node('localhost', :worker_2_port);
- citus_remove_node
+select 1 from citus_remove_node('localhost', :worker_2_port);
+ ?column?
 ---------------------------------------------------------------------
-
+        1
 (1 row)
 
 SET citus.log_remote_commands = true;
@@ -1654,11 +1654,11 @@ SELECT result from run_command_on_all_nodes(
 (2 rows)
 
 SET citus.log_remote_commands = true;
-select citus_add_node('localhost', :worker_2_port);
+select 1 from citus_add_node('localhost', :worker_2_port);
 NOTICE:  issuing SET citus.enable_ddl_propagation TO 'off';select pg_catalog.citus_internal_database_command( 'CREATE DATABASE postgres OWNER = postgres ENCODING = ''UTF8'' LC_COLLATE = ''C'' LC_CTYPE = ''C'' LOCALE_PROVIDER = ''libc'' TABLESPACE = pg_default ALLOW_CONNECTIONS = ''true'' IS_TEMPLATE = ''false''');select pg_catalog.citus_internal_database_command( 'CREATE DATABASE regression OWNER = postgres ENCODING = ''UTF8'' LC_COLLATE = ''C'' LC_CTYPE = ''C'' LOCALE_PROVIDER = ''libc'' TABLESPACE = pg_default ALLOW_CONNECTIONS = ''true'' IS_TEMPLATE = ''false''');select pg_catalog.citus_internal_database_command( 'CREATE DATABASE template1 OWNER = postgres ENCODING = ''UTF8'' LC_COLLATE = ''C'' LC_CTYPE = ''C'' LOCALE_PROVIDER = ''libc'' TABLESPACE = pg_default ALLOW_CONNECTIONS = ''true'' IS_TEMPLATE = ''true''');select pg_catalog.citus_internal_database_command( 'CREATE DATABASE template0 OWNER = postgres ENCODING = ''UTF8'' LC_COLLATE = ''C'' LC_CTYPE = ''C'' LOCALE_PROVIDER = ''libc'' TABLESPACE = pg_default ALLOW_CONNECTIONS = ''false'' IS_TEMPLATE = ''true''');select pg_catalog.citus_internal_database_command( 'CREATE DATABASE mydatabase2 OWNER = create_drop_db_test_user ENCODING = ''UTF8'' LC_COLLATE = ''C'' LC_CTYPE = ''C'' LOCALE_PROVIDER = ''libc'' COLLATION_VERSION = ''1.0'' TABLESPACE = create_drop_db_tablespace ALLOW_CONNECTIONS = ''true'' IS_TEMPLATE = ''false''');ALTER ROLE ALL IN DATABASE regression SET lc_messages = 'C';ALTER ROLE ALL IN DATABASE regression SET lc_monetary = 'C';ALTER ROLE ALL IN DATABASE regression SET lc_numeric = 'C';ALTER ROLE ALL IN DATABASE regression SET lc_time = 'C';ALTER ROLE ALL IN DATABASE regression SET bytea_output = 'hex';ALTER ROLE ALL IN DATABASE regression SET timezone_abbreviations = 'Default';SET citus.enable_ddl_propagation TO 'on'
- citus_add_node
+ ?column?
 ---------------------------------------------------------------------
-             30
+        1
 (1 row)
 
 SET citus.log_remote_commands = false;
diff --git a/src/test/regress/sql/create_drop_database_propagation.sql b/src/test/regress/sql/create_drop_database_propagation.sql
index 6f9202a4b..6b95fd83e 100644
--- a/src/test/regress/sql/create_drop_database_propagation.sql
+++ b/src/test/regress/sql/create_drop_database_propagation.sql
@@ -67,7 +67,7 @@ SELECT result from run_command_on_all_nodes(
 
 -- test database syncing after node addition
 
-select citus_remove_node('localhost', :worker_2_port);
+select 1 from citus_remove_node('localhost', :worker_2_port);
 
 --test with is_template true and allow connections false
 CREATE DATABASE mydatabase
@@ -97,7 +97,7 @@ SELECT result from run_command_on_all_nodes(
   $$
 ) ORDER BY result;
 
-select citus_add_node('localhost', :worker_2_port);
+select 1 from citus_add_node('localhost', :worker_2_port);
 
 SELECT result from run_command_on_all_nodes(
   $$
diff --git a/src/test/regress/sql/pg15.sql b/src/test/regress/sql/pg15.sql
index ac523b521..845d5fab5 100644
--- a/src/test/regress/sql/pg15.sql
+++ b/src/test/regress/sql/pg15.sql
@@ -1048,7 +1048,7 @@ SELECT result from run_command_on_all_nodes(
 ) ORDER BY result;
 
 
-select citus_remove_node('localhost', :worker_2_port);
+select 1 from citus_remove_node('localhost', :worker_2_port);
 
 
 SET citus.log_remote_commands = true;
@@ -1085,7 +1085,7 @@ SELECT result from run_command_on_all_nodes(
 
 
 SET citus.log_remote_commands = true;
-select citus_add_node('localhost', :worker_2_port);
+select 1 from citus_add_node('localhost', :worker_2_port);
 
 SET citus.log_remote_commands = false;
 SELECT result from run_command_on_all_nodes(