This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 80f5c6f4cf [TRACES][OTEL] allow otel_debugging_on to emit traces to
otel host (#43500)
add 6ee5a610e4 Remove pluggable TaskRunners concept (#43551)
No new revisions were added by this update.
Summary of changes:
.github/boring-cyborg.yml | 2 +-
airflow/config_templates/config.yml | 9 -
airflow/jobs/local_task_job_runner.py | 4 +-
.../task/{task_runner => }/standard_task_runner.py | 136 +++++++++++-
airflow/task/task_runner/__init__.py | 66 ------
airflow/task/task_runner/base_task_runner.py | 202 -----------------
airflow/task/task_runner/cgroup_task_runner.py | 246 ---------------------
newsfragments/aip-72.significant.rst | 15 ++
.../tests/openlineage/plugins/test_execution.py | 8 +-
tests/cli/commands/test_config_command.py | 24 +-
tests/cli/commands/test_task_command.py | 4 +-
tests/core/test_configuration.py | 12 +-
tests/jobs/test_local_task_job.py | 10 +-
tests/task/{task_runner => }/conftest.py | 7 +-
tests/task/task_runner/__init__.py | 17 --
tests/task/task_runner/test_base_task_runner.py | 59 -----
tests/task/task_runner/test_cgroup_task_runner.py | 45 ----
tests/task/task_runner/test_task_runner.py | 66 ------
.../{task_runner => }/test_standard_task_runner.py | 36 ++-
19 files changed, 218 insertions(+), 750 deletions(-)
rename airflow/task/{task_runner => }/standard_task_runner.py (62%)
delete mode 100644 airflow/task/task_runner/__init__.py
delete mode 100644 airflow/task/task_runner/base_task_runner.py
delete mode 100644 airflow/task/task_runner/cgroup_task_runner.py
create mode 100644 newsfragments/aip-72.significant.rst
rename tests/task/{task_runner => }/conftest.py (89%)
delete mode 100644 tests/task/task_runner/__init__.py
delete mode 100644 tests/task/task_runner/test_base_task_runner.py
delete mode 100644 tests/task/task_runner/test_cgroup_task_runner.py
delete mode 100644 tests/task/task_runner/test_task_runner.py
rename tests/task/{task_runner => }/test_standard_task_runner.py (92%)
