From 2a011164f212b463c059919dd03cf8107aa14992 Mon Sep 17 00:00:00 2001
From: Sait Talha Nisanci <s.talhanisanci@gmail.com>
Date: Fri, 3 Jul 2020 15:24:43 +0300
Subject: [PATCH] test

---
 .circleci/config.yml                          |  32 ++---
 src/test/regress/sql/connection_count.sql     | 133 +++++++++---------
 .../sql/multi_mx_repartition_udt_w1.sql       |   2 +
 .../sql/multi_mx_repartition_udt_w2.sql       |   1 +
 4 files changed, 85 insertions(+), 83 deletions(-)

diff --git a/.circleci/config.yml b/.circleci/config.yml
index 6f3b4af86..005f1efa5 100644
--- a/.circleci/config.yml
+++ b/.circleci/config.yml
@@ -292,27 +292,27 @@ workflows:
       - check-style
       - check-sql-snapshots
 
-      - test-11_check-multi:
-          requires: [build]
+      # - test-11_check-multi:
+      #     requires: [build]
       - test-11_check-tt-van-mx:
           requires: [build]
-      - test-11_check-iso-work-fol:
-          requires: [build]
-      - test-11_check-fol:
-          requires: [build]
-      - test-11_check-failure:
-          requires: [build]
+      # - test-11_check-iso-work-fol:
+      #     requires: [build]
+      # - test-11_check-fol:
+      #     requires: [build]
+      # - test-11_check-failure:
+      #     requires: [build]
 
-      - test-12_check-multi:
-          requires: [build]
+      # - test-12_check-multi:
+      #     requires: [build]
       - test-12_check-tt-van-mx:
           requires: [build]
-      - test-12_check-iso-work-fol:
-          requires: [build]
-      - test-12_check-fol:
-          requires: [build]
-      - test-12_check-failure:
-          requires: [build]
+      # - test-12_check-iso-work-fol:
+      #     requires: [build]
+      # - test-12_check-fol:
+      #     requires: [build]
+      # - test-12_check-failure:
+      #     requires: [build]
 
       - test-11-12_check-pg-upgrade:
           requires: [build]
diff --git a/src/test/regress/sql/connection_count.sql b/src/test/regress/sql/connection_count.sql
index 2bb759db6..c5d65b3ea 100644
--- a/src/test/regress/sql/connection_count.sql
+++ b/src/test/regress/sql/connection_count.sql
@@ -1,137 +1,136 @@
 
-select pg_sleep(0.05);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
-select pg_sleep(0.05);
+select pg_sleep(0.01);
 
 
 
diff --git a/src/test/regress/sql/multi_mx_repartition_udt_w1.sql b/src/test/regress/sql/multi_mx_repartition_udt_w1.sql
index 96cb59b93..8ae77daa7 100644
--- a/src/test/regress/sql/multi_mx_repartition_udt_w1.sql
+++ b/src/test/regress/sql/multi_mx_repartition_udt_w1.sql
@@ -1,6 +1,7 @@
 --
 -- MULTI_MX_REPARTITION_W1_UDT
 --
+SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
 
 \c - - - :worker_1_port
 SET client_min_messages = LOG;
@@ -10,6 +11,7 @@ SET citus.enable_repartition_joins to ON;
 SET citus.task_executor_type = 'adaptive';
 SET citus.log_multi_join_order = true;
 
+
 -- Query that should result in a repartition
 -- join on int column, and be empty
 SELECT * FROM repartition_udt JOIN repartition_udt_other
diff --git a/src/test/regress/sql/multi_mx_repartition_udt_w2.sql b/src/test/regress/sql/multi_mx_repartition_udt_w2.sql
index 604e54041..5e267bfae 100644
--- a/src/test/regress/sql/multi_mx_repartition_udt_w2.sql
+++ b/src/test/regress/sql/multi_mx_repartition_udt_w2.sql
@@ -1,6 +1,7 @@
 --
 -- MULTI_MX_REPARTITION_W2_UDT
 --
+SELECT run_command_on_workers($$SELECT sum(numbackends) FROM pg_stat_database;$$);
 
 \c - - - :worker_2_port
 SET client_min_messages = LOG;