This is an automated email from the ASF dual-hosted git repository.
weilee pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from f59f0226e76 Extract secrets explicitly and assign (#47278)
add ccd126f595f feat(task_sdk): add support for inlet_events in Task
Context (#45960)
No new revisions were added by this update.
Summary of changes:
.../datamodels/{asset.py => asset_event.py} | 47 +++---
.../api_fastapi/execution_api/routes/__init__.py | 2 +
.../execution_api/routes/asset_events.py | 111 +++++++++++++
airflow/models/taskinstance.py | 4 +-
airflow/utils/context.py | 125 +-------------
newsfragments/45960.significant.rst | 37 +++++
task_sdk/src/airflow/sdk/api/client.py | 27 +++
.../src/airflow/sdk/api/datamodels/_generated.py | 42 +++++
task_sdk/src/airflow/sdk/definitions/context.py | 4 +-
task_sdk/src/airflow/sdk/execution_time/comms.py | 37 +++++
task_sdk/src/airflow/sdk/execution_time/context.py | 75 +++++++++
.../src/airflow/sdk/execution_time/supervisor.py | 11 ++
.../src/airflow/sdk/execution_time/task_runner.py | 3 +-
task_sdk/tests/execution_time/test_context.py | 58 ++++++-
task_sdk/tests/execution_time/test_supervisor.py | 99 ++++++++++-
task_sdk/tests/execution_time/test_task_runner.py | 56 ++++++-
.../execution_api/routes/test_asset_events.py | 184 +++++++++++++++++++++
tests/models/test_taskinstance.py | 88 ++++++++--
18 files changed, 849 insertions(+), 161 deletions(-)
copy airflow/api_fastapi/execution_api/datamodels/{asset.py => asset_event.py}
(51%)
create mode 100644 airflow/api_fastapi/execution_api/routes/asset_events.py
create mode 100644 newsfragments/45960.significant.rst
create mode 100644 tests/api_fastapi/execution_api/routes/test_asset_events.py
