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 830a2a53f8d Dont add extra deps for providers with same cross provider
deps (#44341)
add 14919fae914 Convert the LocalExecutor to run tasks using new Task SDK
supervisor code (#44427)
No new revisions were added by this update.
Summary of changes:
airflow/cli/commands/task_command.py | 32 +++--
airflow/config_templates/config.yml | 2 +-
airflow/executors/base_executor.py | 7 ++
airflow/executors/local_executor.py | 140 ++++++---------------
airflow/executors/workloads.py | 98 +++++++++++++++
airflow/jobs/scheduler_job_runner.py | 11 +-
airflow/utils/helpers.py | 25 +++-
task_sdk/pyproject.toml | 1 +
.../src/airflow/sdk/execution_time/supervisor.py | 71 ++++++++---
.../src/airflow/sdk/execution_time/task_runner.py | 4 +
task_sdk/src/airflow/sdk/log.py | 81 ++++++++++--
task_sdk/tests/execution_time/test_supervisor.py | 19 ++-
tests/executors/test_local_executor.py | 77 ++++++------
tests/jobs/test_scheduler_job.py | 6 +
14 files changed, 383 insertions(+), 191 deletions(-)
create mode 100644 airflow/executors/workloads.py
