[airflow] branch main updated: Fix dag-processor fetch metabase config (#23575)

[potiuk]

This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 9837e6d813 Fix dag-processor fetch metabase config (#23575)
9837e6d813 is described below

commit 9837e6d813744e3c5861c32e87b3aeb496d0f88d
Author: Andrey Anshin <andrey.ans...@river-island.com>
AuthorDate: Mon May 9 11:50:33 2022 +0300

    Fix dag-processor fetch metabase config (#23575)
---
 airflow/cli/commands/dag_processor_command.py    | 2 +-
 tests/cli/commands/test_dag_processor_command.py | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/airflow/cli/commands/dag_processor_command.py 
b/airflow/cli/commands/dag_processor_command.py
index a07035be50..183b77dbe2 100644
--- 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
index 39241a96de..8129c31047 100644
--- a/tests/cli/commands/test_dag_processor_command.py
+++ b/tests/cli/commands/test_dag_processor_command.py
@@ -43,7 +43,7 @@ class TestDagProcessorCommand(unittest.TestCase):
     )
     
@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(