Repository navigation

Support multiple DagProcessors parsing files from different locations. - #25935

Merged

ashb merged 19 commits into

apache:mainfrom

mhenc:multiple_dp

Sep 6, 2022

Commits on Sep 6, 2022
- Separate dag processors
  mhenc
  committed
  0448f90
- Introduce [scheduler]stalled_dags_update_timeout configuration option
  mhenc
  committed
  a8f1072
- Remove DagProcessorDirectory class and pass dag_directory as parameter
  mhenc
  committed
  d480e80
- Update airflow/dag_processing/manager.py
  
  mhenc
  and
  ashb
  committed
  7adfdf4
- Update airflow/dag_processing/manager.py
  
  mhenc
  and
  ashb
  committed
  97f30f0
- Fixes after merge
  mhenc
  committed
  16519b8
- Update airflow/jobs/scheduler_job.py
  
  mhenc
  and
  ashb
  committed
  dc398fa
- Update tests/models/test_dagbag.py
  
  mhenc
  and
  ashb
  committed
  2e36013
- Update airflow/jobs/scheduler_job.py
  
  mhenc
  and
  ashb
  committed
  19d69b3
- Update airflow/jobs/scheduler_job.py
  
  mhenc
  and
  ashb
  committed
  7403031
- Rename dag_directory to processor_subdir
  mhenc
  committed
  59059a2
- remove typechecking from manager.py
  mhenc
  committed
  a5b8c57
- Remove unused comment
  mhenc
  committed
  a0b05eb
- Rename dag_directory column to processor_subdir in CallbackRequests
  mhenc
  committed
  a05f227
- Fix sql statements.
  mhenc
  committed
  b017c53
- Fix scheduler_job test after merge
  mhenc
  committed
  30cee80
- Update airflow/config_templates/config.yml
  
  mhenc
  and
  ashb
  committed
  df31ed5
- Update airflow/jobs/scheduler_job.py
  
  mhenc
  and
  ashb
  committed
  9f9efcd
- revert changes to Dag.bulk_sync_to_db
  mhenc
  committed
  a44e9f6

Navigation Menu

Repository navigation

Support multiple DagProcessors parsing files from different locations. - #25935

Support multiple DagProcessors parsing files from different locations.#25935
ashb merged 19 commits into
apache:mainfrom
mhenc:multiple_dp

Commits on Sep 6, 2022

Separate dag processors

Introduce [scheduler]stalled_dags_update_timeout configuration option

Remove DagProcessorDirectory class and pass dag_directory as parameter

Update airflow/dag_processing/manager.py

Update airflow/dag_processing/manager.py

Fixes after merge

Update airflow/jobs/scheduler_job.py

Update tests/models/test_dagbag.py

Update airflow/jobs/scheduler_job.py

Update airflow/jobs/scheduler_job.py

Rename dag_directory to processor_subdir

remove typechecking from manager.py

Remove unused comment

Rename dag_directory column to processor_subdir in CallbackRequests

Fix sql statements.

Fix scheduler_job test after merge

Update airflow/config_templates/config.yml

Update airflow/jobs/scheduler_job.py

revert changes to Dag.bulk_sync_to_db