This is an automated email from the ASF dual-hosted git repository.
ephraimanierobi pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 1ebeb19bf7 Add `max_active_tis_per_dagrun` for Dynamic Task Mapping
(#29094)
add 6f2277c83a Simplify logic to resolve tasks stuck in queued despite
stalled_task_timeout (#30375)
No new revisions were added by this update.
Summary of changes:
airflow/config_templates/config.yml | 57 ++-----
airflow/config_templates/default_airflow.cfg | 29 +---
airflow/configuration.py | 30 +++-
airflow/executors/base_executor.py | 12 ++
airflow/executors/celery_executor.py | 160 +++----------------
airflow/executors/celery_kubernetes_executor.py | 8 +
airflow/executors/kubernetes_executor.py | 77 +++++----
airflow/executors/local_kubernetes_executor.py | 6 +
airflow/jobs/scheduler_job_runner.py | 83 +++++++++-
airflow/kubernetes/kube_config.py | 7 -
docs/conf.py | 4 +
newsfragments/30375.significant.rst | 9 ++
tests/executors/test_base_executor.py | 1 -
tests/executors/test_celery_executor.py | 139 +++-------------
tests/executors/test_kubernetes_executor.py | 177 +++------------------
.../integration/executors/test_celery_executor.py | 5 +-
tests/jobs/test_scheduler_job.py | 41 ++++-
17 files changed, 301 insertions(+), 544 deletions(-)
create mode 100644 newsfragments/30375.significant.rst