This is an automated email from the ASF dual-hosted git repository.
pierrejeambrun pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 3dbed17b0ef AIP-72 Add default api version for Execution API (#48548)
add 683cae4a7d0 Enable Comms in the TriggerRunner to make Connections,
Variables and XComs accessible to Triggers (#48239)
No new revisions were added by this update.
Summary of changes:
.../src/airflow/dag_processing/processor.py | 1 -
airflow-core/src/airflow/executors/workloads.py | 6 +-
airflow-core/src/airflow/hooks/base.py | 2 +-
.../src/airflow/jobs/triggerer_job_runner.py | 112 +++++++++++++---
airflow-core/tests/unit/jobs/test_triggerer_job.py | 147 ++++++++++++++++++++-
airflow-core/tests/unit/models/test_dagrun.py | 3 -
task-sdk/src/airflow/sdk/bases/xcom.py | 58 ++++----
task-sdk/src/airflow/sdk/execution_time/comms.py | 2 +-
task-sdk/src/airflow/sdk/execution_time/context.py | 21 ++-
.../src/airflow/sdk/execution_time/task_runner.py | 12 +-
10 files changed, 304 insertions(+), 60 deletions(-)
