Fix dag-processor fetch metabase config (#23575)

apache · May 9, 2022 · 9837e6d · 9837e6d
1 parent 827bfda
commit 9837e6d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/airflow/cli/commands/dag_processor_command.py b/airflow/cli/commands/dag_processor_command.py
@@ -50,7 +50,7 @@ def dag_processor(args):
     if not conf.getboolean("scheduler", "standalone_dag_processor"):
         raise SystemExit('The option [scheduler/standalone_dag_processor] must be True.')
 
-    sql_conn: str = conf.get('core', 'sql_alchemy_conn').lower()
+    sql_conn: str = conf.get('database', 'sql_alchemy_conn').lower()
     if sql_conn.startswith('sqlite'):
         raise SystemExit('Standalone DagProcessor is not supported when using sqlite.')
 

diff --git a/tests/cli/commands/test_dag_processor_command.py b/tests/cli/commands/test_dag_processor_command.py
@@ -43,7 +43,7 @@ def setUpClass(cls):
     )
     @mock.patch("airflow.cli.commands.dag_processor_command.DagFileProcessorManager")
     @pytest.mark.skipif(
-        conf.get('core', 'sql_alchemy_conn').lower().startswith('sqlite'),
+        conf.get('database', 'sql_alchemy_conn').lower().startswith('sqlite'),
         reason="Standalone Dag Processor doesn't support sqlite.",
     )
     def test_start_manager(