This is an automated email from the ASF dual-hosted git repository.
ferruzzi pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from bfe46f61cc0 UI: Rework Monaco editor theme to match Chakra UI palette
(#64748)
add ec6700db077 Move ExecutorCallback execution into a supervised process
(#62645)
No new revisions were added by this update.
Summary of changes:
airflow-core/.pre-commit-config.yaml | 2 +-
.../src/airflow/executors/base_executor.py | 83 +++++-
.../src/airflow/executors/local_executor.py | 116 +++-----
.../src/airflow/executors/workloads/__init__.py | 7 +
.../src/airflow/executors/workloads/base.py | 72 ++++-
.../src/airflow/executors/workloads/callback.py | 91 ++----
.../src/airflow/executors/workloads/task.py | 19 ++
airflow-core/src/airflow/models/callback.py | 14 +-
airflow-core/src/airflow/triggers/callback.py | 6 +-
.../tests/unit/executors/test_base_executor.py | 78 ++---
.../tests/unit/executors/test_local_executor.py | 135 ++++++---
airflow-core/tests/unit/models/test_callback.py | 14 +-
.../celery/executors/celery_executor_utils.py | 40 ++-
.../unit/celery/executors/test_celery_executor.py | 9 +-
.../src/airflow/providers/edge3/cli/worker.py | 2 +-
.../src/airflow_shared/module_loading/__init__.py | 28 ++
task-sdk/.pre-commit-config.yaml | 1 +
.../sdk/execution_time/callback_supervisor.py | 317 +++++++++++++++++++++
.../airflow/sdk/execution_time/execute_workload.py | 26 +-
.../src/airflow/sdk/execution_time/supervisor.py | 29 +-
.../execution_time/test_callback_supervisor.py | 115 ++++++++
.../task_sdk/execution_time/test_supervisor.py | 13 +-
22 files changed, 905 insertions(+), 312 deletions(-)
create mode 100644
task-sdk/src/airflow/sdk/execution_time/callback_supervisor.py
create mode 100644
task-sdk/tests/task_sdk/execution_time/test_callback_supervisor.py
