[airflow] branch v2-3-test updated: Use '--subdir' argument value for standalong dag processor. (#23864)

[jedcunningham]

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

jedcunningham pushed a commit to branch v2-3-test
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/v2-3-test by this push:
     new 18a6c88417 Use '--subdir' argument value for standalong dag processor. 
(#23864)
18a6c88417 is described below

commit 18a6c884173a09a454083c381e7770fbe0f3bf38
Author: mhenc <mh...@google.com>
AuthorDate: Fri May 27 04:47:32 2022 +0200

    Use '--subdir' argument value for standalong dag processor. (#23864)
    
    (cherry picked from commit 188ec4a8d61bdb536c33c9aa518f5acc13b0896e)
---
 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 db7ed443a3..d57e26510c 100644
--- a/airflow/cli/commands/dag_processor_command.py
+++ b/airflow/cli/commands/dag_processor_command.py
@@ -22,7 +22,6 @@ from datetime import timedelta
 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=[],