You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ep...@apache.org on 2022/05/19 11:59:21 UTC
[airflow] 04/04: Fix dag-processor fetch metabase config (#23575)
This is an automated email from the ASF dual-hosted git repository.
ephraimanierobi pushed a commit to branch v2-3-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit d07392fe15d30b61631de30c55b91dd0843bfef3
Author: Andrey Anshin <An...@river-island.com>
AuthorDate: Mon May 9 11:50:33 2022 +0300
Fix dag-processor fetch metabase config (#23575)
(cherry picked from commit 9837e6d813744e3c5861c32e87b3aeb496d0f88d)
---
airflow/cli/commands/dag_processor_command.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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.')