Revert "Load default Airflow connections on initialization (#182)"

This reverts commit f71d082.
aws · Nov 27, 2024 · e1fd3b6 · e1fd3b6
1 parent f71d082
commit e1fd3b6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 23 deletions.
diff --git a/images/airflow/2.10.1/python/mwaa/database/migrate.py b/images/airflow/2.10.1/python/mwaa/database/migrate.py
@@ -55,21 +55,10 @@ def _migrate_db():
         logging.info("The database is now migrated.")
 
 
-@with_db_lock(1234)
-def _create_default_connections():
-    from airflow.cli.commands import connection_command as airflow_connection_command
-
-    try:
-        args = Namespace(verbose=False)
-        airflow_connection_command.create_default_connections(args)
-        logging.info("The default Airflow connections have been created.")
-    except TimeoutError:
-        logging.warning("Timed out on initializatin of default Airflow connections.")
-
 def _main():
     _verify_environ()
     _migrate_db()
-    _create_default_connections()
+
 
 if __name__ == "__main__":
     _main()

diff --git a/images/airflow/2.9.2/python/mwaa/database/migrate.py b/images/airflow/2.9.2/python/mwaa/database/migrate.py
@@ -54,21 +54,11 @@ def _migrate_db():
         airflow_db_command.migratedb(args)
         logging.info("The database is now migrated.")
 
-@with_db_lock(1234)
-def _create_default_connections():
-    from airflow.cli.commands import connection_command as airflow_connection_command
-
-    try:
-        args = Namespace(verbose=False)
-        airflow_connection_command.create_default_connections(args)
-        logging.info("The default Airflow connections have been created.")
-    except TimeoutError:
-        logging.warning("Timed out on initializatin of default Airflow connections.")
 
 def _main():
     _verify_environ()
     _migrate_db()
-    _create_default_connections()
+
 
 if __name__ == "__main__":
     _main()