Fixes flaky tests

pull/7240/head
gindibay 2023-10-27 10:10:42 +03:00
parent fe26aebf6c
commit 2a6c40d643
4 changed files with 16 additions and 16 deletions

View File

@ -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(

View File

@ -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;

View File

@ -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(
$$

View File

@ -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(