Skip to content

Commit

Permalink
Use '--subdir' argument value for standalong dag processor. (#23864)
Browse files Browse the repository at this point in the history
  • Loading branch information
mhenc authored May 27, 2022
1 parent 80c3fcd commit 188ec4a
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions airflow/cli/commands/dag_processor_command.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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=[],
Expand Down

0 comments on commit 188ec4a

Please sign in to comment.