From ac8bb8dd1b0e7f41b1adbfe465a4c9e9a91d16ac Mon Sep 17 00:00:00 2001 From: Mateusz Henc Date: Mon, 23 May 2022 11:00:43 +0000 Subject: [PATCH] Use '--subdir' argument value for standalong dag processor. --- 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 183b77dbe26b1c..f026b25abc9472 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=[],