This is an automated email from the ASF dual-hosted git repository.
jason810496 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from fe8e5dfef07 Close S3 download_file handle once the download finishes
or fails (#69084)
add 9b6f6d30b1b Add NodeCoordinator (#68548)
No new revisions were added by this update.
Summary of changes:
airflow-core/newsfragments/68548.feature.rst | 1 +
.../sdk/coordinators/{java => node}/__init__.py | 9 +-
.../airflow/sdk/coordinators/node/coordinator.py | 174 +++++++++++++++++
.../tests/task_sdk/coordinators/node}/__init__.py | 0
.../task_sdk/coordinators/node/test_coordinator.py | 205 +++++++++++++++++++++
ts-sdk/README.md | 27 ++-
6 files changed, 407 insertions(+), 9 deletions(-)
create mode 100644 airflow-core/newsfragments/68548.feature.rst
copy task-sdk/src/airflow/sdk/coordinators/{java => node}/__init__.py (80%)
create mode 100644 task-sdk/src/airflow/sdk/coordinators/node/coordinator.py
copy {airflow-core/src/airflow/api/common =>
task-sdk/tests/task_sdk/coordinators/node}/__init__.py (100%)
create mode 100644
task-sdk/tests/task_sdk/coordinators/node/test_coordinator.py
