This is an automated email from the ASF dual-hosted git repository.
jhtimmins pushed a change to branch v2-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git.
from 0bd9558 Proper warning message when recorded PID is different from
current PID (#17411)
new f7bece3 Add 'queued' state to DagRun (#16401)
new 38d4bab Fix race condition with dagrun callbacks (#16741)
new 205d6d4 Run mini scheduler in LocalTaskJob during task exit (#16289)
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
airflow/api_connexion/openapi/v1.yaml | 4 +-
airflow/jobs/local_task_job.py | 68 +-
airflow/jobs/scheduler_job.py | 165 ++---
...3827b8_add_queued_at_column_to_dagrun_table.py} | 25 +-
airflow/models/dag.py | 4 +-
airflow/models/dagrun.py | 17 +-
airflow/models/taskinstance.py | 66 +-
airflow/www/static/js/tree.js | 4 +-
airflow/www/views.py | 5 +-
docs/apache-airflow/migrations-ref.rst | 4 +-
tests/api/common/experimental/test_mark_tasks.py | 4 +-
.../endpoints/test_dag_run_endpoint.py | 14 +-
tests/api_connexion/schemas/test_dag_run_schema.py | 3 +
tests/cli/commands/test_task_command.py | 4 +-
tests/dag_processing/test_processor.py | 750 +++++++++++++++++++++
tests/jobs/test_local_task_job.py | 130 +++-
tests/jobs/test_scheduler_job.py | 278 ++++----
tests/models/test_cleartasks.py | 37 +
tests/models/test_dagrun.py | 25 +-
tests/models/test_taskinstance.py | 103 ---
tests/sensors/test_external_task_sensor.py | 8 +-
tests/utils/test_dag_processing.py | 11 +-
22 files changed, 1264 insertions(+), 465 deletions(-)
copy airflow/migrations/versions/{4446e08588_dagrun_start_end.py =>
97cdd93827b8_add_queued_at_column_to_dagrun_table.py} (60%)
create mode 100644 tests/dag_processing/test_processor.py
