You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@airflow.apache.org by po...@apache.org on 2022/04/01 20:52:08 UTC

[airflow] branch main updated (e048e1a -> f5f11ae)

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

potiuk pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git.


    from e048e1a  Fix StatsD casing and helm chart StatsD comments (#22610)
     add f5f11ae  Add dag-processor cli command (#22305)

No new revisions were added by this update.

Summary of changes:
 airflow/cli/cli_parser.py                          |  15 ++
 airflow/cli/commands/dag_processor_command.py      |  79 ++++++
 airflow/dag_processing/manager.py                  |  67 ++---
 airflow/jobs/scheduler_job.py                      |  74 +++---
 ...er_command.py => test_dag_processor_command.py} |  34 ++-
 tests/dag_processing/test_manager.py               |  13 +-
 tests/jobs/test_scheduler_job.py                   | 290 ++++++++++++---------
 7 files changed, 361 insertions(+), 211 deletions(-)
 create mode 100644 airflow/cli/commands/dag_processor_command.py
 copy tests/cli/commands/{test_triggerer_command.py => test_dag_processor_command.py} (51%)