This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a change to branch v3-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
from d47704734e6 Prevent `DetachedInstanceError` when processing executor
event (#54334)
new d13713eb338 Allow `DEFAULT_QUEUE` to be configurable from airflow
settings in Task SDK (#52786)
new 2d2eedd0def Fix task configuration defaults for AbstractOperator
(#52871)
new 03a78e8bbef Add note about ruff rules and preview flag (#53331)
new 4ad2433c3c6 Fix broken link in advanced logging config docs (#53460)
new 257735fc790 Update dag bundles docs; add s3, fix git classpath (#53473)
new 18e17f2f37a Fixed Task group names duplication in Task's task_id for
MappedOperator (#53532)
new 2b993bea5be Fix custom xcom backend serialize when BaseXCom.get_all is
used (#53814)
new 2b34a654440 Restore ``get_previous_dagrun`` functionality for task
context (#53655)
new cd60cfc5dfc Do not ignore `include_prior_dates` in xcom_pull when
`map_indexes` is not specified (#53809)
new 3edbef7c083 Allow setting and deleting variables and xcoms from
triggers (#53514)
new 8e2a348abe2 Fix type error with TIH when reading served log (#54114)
The 11 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:
.../administration-and-deployment/dag-bundles.rst | 5 +-
.../advanced-logging-configuration.rst | 2 +-
.../docs/installation/upgrading_to_airflow3.rst | 18 ++-
.../execution_api/datamodels/taskinstance.py | 8 +-
.../api_fastapi/execution_api/routes/dag_runs.py | 45 ++++++-
.../api_fastapi/execution_api/routes/xcoms.py | 2 +
.../api_fastapi/execution_api/versions/__init__.py | 9 ++
.../execution_api/versions/v2025_08_10.py | 50 ++++++++
.../src/airflow/jobs/triggerer_job_runner.py | 20 +++
airflow-core/src/airflow/models/__init__.py | 21 +++
.../src/airflow/models/abstractoperator.py | 34 -----
.../src/airflow/utils/log/file_task_handler.py | 4 +-
.../execution_api/versions/head/test_dag_runs.py | 139 ++++++++++++++++++++
.../versions/head/test_task_instances.py | 4 +-
.../execution_api/versions/head/test_xcoms.py | 49 +++++++
.../tests/unit/dag_processing/test_processor.py | 2 +
airflow-core/tests/unit/jobs/test_triggerer_job.py | 100 ++++++++++++---
.../unit/serialization/test_dag_serialization.py | 2 +
airflow-core/tests/unit/utils/test_log_handlers.py | 12 ++
devel-common/src/tests_common/pytest_plugin.py | 27 ++--
.../providers/edge3/executors/edge_executor.py | 6 +-
.../unit/openlineage/plugins/test_listener.py | 29 +++--
task-sdk/src/airflow/sdk/api/client.py | 21 +++
.../src/airflow/sdk/api/datamodels/_generated.py | 3 +-
task-sdk/src/airflow/sdk/bases/operator.py | 8 +-
task-sdk/src/airflow/sdk/bases/xcom.py | 16 ++-
.../sdk/definitions/_internal/abstractoperator.py | 21 ++-
.../sdk/definitions/decorators/__init__.pyi | 4 +-
.../src/airflow/sdk/definitions/mappedoperator.py | 10 +-
task-sdk/src/airflow/sdk/execution_time/comms.py | 18 +++
.../src/airflow/sdk/execution_time/supervisor.py | 16 ++-
.../src/airflow/sdk/execution_time/task_runner.py | 28 ++++
task-sdk/src/airflow/sdk/types.py | 2 +
task-sdk/tests/conftest.py | 2 +
task-sdk/tests/task_sdk/api/test_client.py | 82 ++++++++++++
.../task_sdk/definitions/test_mappedoperator.py | 22 ++++
.../tests/task_sdk/execution_time/test_comms.py | 1 +
.../task_sdk/execution_time/test_supervisor.py | 73 ++++++++++-
.../task_sdk/execution_time/test_task_runner.py | 142 ++++++++++++++++++++-
39 files changed, 941 insertions(+), 116 deletions(-)
create mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2025_08_10.py
delete mode 100644 airflow-core/src/airflow/models/abstractoperator.py
