From 188ec4a8d61bdb536c33c9aa518f5acc13b0896e Mon Sep 17 00:00:00 2001 From: mhenc Date: Fri, 27 May 2022 04:47:32 +0200 Subject: [PATCH] Use '--subdir' argument value for standalong dag processor. (#23864) --- airflow/cli/commands/dag_processor_command.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/airflow/cli/commands/dag_processor_command.py b/airflow/cli/commands/dag_processor_command.py index db7ed443a31228..d57e26510c9749 100644 --- a/airflow/cli/commands/dag_processor_command.py +++ b/airflow/cli/commands/dag_processor_command.py @@ -22,7 +22,6 @@ import daemon from daemon.pidfile import TimeoutPIDLockFile -from airflow import settings from airflow.configuration import conf from airflow.dag_processing.manager import DagFileProcessorManager from airflow.utils import cli as cli_utils @@ -36,7 +35,7 @@ def _create_dag_processor_manager(args) -> DagFileProcessorManager: processor_timeout_seconds: int = conf.getint('core', 'dag_file_processor_timeout') processor_timeout = timedelta(seconds=processor_timeout_seconds) return DagFileProcessorManager( - dag_directory=settings.DAGS_FOLDER, + dag_directory=args.subdir, max_runs=args.num_runs, processor_timeout=processor_timeout, dag_ids=[],