[AIRFLOW-6987] Avoid creating default connections (#7629)

airflow/config_templates/config.yml

@@ -184,13 +184,22 @@
       default: "16"
     - name: load_examples
       description: |
-        Whether to load the examples that ship with Airflow. It's good to
+        Whether to load the DAG examples that ship with Airflow. It's good to
         get started, but you probably want to set this to False in a production
         environment
       version_added: ~
       type: string
       example: ~
       default: "True"
+    - name: load_default_connections
+      description: |
+        Whether to load the default connections that ship with Airflow. It's good to
+        get started, but you probably want to set this to False in a production
+        environment
+      version_added: 1.10.10
+      type: string
+      example: ~
+      default: "True"
     - name: plugins_folder
       description: |
         Where your Airflow plugins are stored

airflow/config_templates/default_airflow.cfg

@@ -119,11 +119,16 @@ dags_are_paused_at_creation = True
 # The maximum number of active DAG runs per DAG
 max_active_runs_per_dag = 16
 
-# Whether to load the examples that ship with Airflow. It's good to
+# Whether to load the DAG examples that ship with Airflow. It's good to
 # get started, but you probably want to set this to False in a production
 # environment
 load_examples = True
 
+# Whether to load the default connections that ship with Airflow. It's good to
+# get started, but you probably want to set this to False in a production
+# environment
+load_default_connections = True
+
 # Where your Airflow plugins are stored
 plugins_folder = {AIRFLOW_HOME}/plugins
 

airflow/config_templates/default_test.cfg

@@ -35,6 +35,7 @@ plugins_folder = {TEST_PLUGINS_FOLDER}
 executor = SequentialExecutor
 sql_alchemy_conn = sqlite:///{AIRFLOW_HOME}/unittests.db
 load_examples = True
+load_default_connections = True
 donot_pickle = True
 dag_concurrency = 16
 dags_are_paused_at_creation = False

airflow/utils/db.py

@@ -503,7 +503,8 @@ def initdb():
     """
     upgradedb()
 
-    create_default_connections()
+    if conf.getboolean('core', 'LOAD_DEFAULT_CONNECTIONS'):
+        create_default_connections()
 
     dagbag = DagBag()
     # Save DAGs in the ORM

scripts/ci/in_container/airflow_ci.cfg

@@ -23,6 +23,7 @@ sql_alchemy_conn = # overridden by the startup scripts
 #sql_engine_collation_for_ids = overridden by the startup scripts
 unit_test_mode = True
 load_examples = True
+load_default_connections = True
 donot_pickle = False
 dags_are_paused_at_creation = False
 default_impersonation =

scripts/ci/in_container/kubernetes/app/templates/configmaps.template.yaml

@@ -27,6 +27,7 @@ data:
     executor = KubernetesExecutor
     parallelism = 32
     load_examples = False
+    load_default_connections = True
     plugins_folder = /root/airflow/plugins
     sql_alchemy_conn = $SQL_ALCHEMY_CONN
 

scripts/perf/sql_queries.py

@@ -27,6 +27,7 @@ DAG_FOLDER = os.path.join(os.path.dirname(__file__), "dags")
 os.environ["AIRFLOW__CORE__DAGS_FOLDER"] = DAG_FOLDER
 os.environ["AIRFLOW__DEBUG__SQLALCHEMY_STATS"] = "True"
 os.environ["AIRFLOW__CORE__LOAD_EXAMPLES"] = "False"
+os.environ["AIRFLOW__CORE__LOAD_DEFAULT_CONNECTIONS"] = "True"
 
 # Here we setup simpler logger to avoid any code changes in
 # Airflow core code base

tests/test_configuration.py

@@ -118,6 +118,8 @@ class TestConf(unittest.TestCase):
         cfg_dict = conf.as_dict(display_source=True)
         self.assertEqual(
             cfg_dict['core']['load_examples'][1], 'airflow.cfg')
+        self.assertEqual(
+            cfg_dict['core']['load_default_connections'][1], 'airflow.cfg')
         self.assertEqual(
             cfg_dict['testsection']['testkey'], ('< hidden >', 'env var'))