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 b191cc4767b Fail instead of silently falling behind when a Lang-SDK
vendored Dag schema drifts from airflow-core (#74091)
add e0202f40c78 Let a Dag importer find the coordinator that parses its
files (#74042)
No new revisions were added by this update.
Summary of changes:
.../adr/lang-sdk/0010-native-dag-processing.md | 106 +++----
.../src/airflow/config_templates/config.yml | 14 +
.../src/airflow/sdk/coordinators/_dag_importer.py | 142 +++++++++
.../src/airflow/sdk/coordinators/_subprocess.py | 127 ++++++--
.../src/airflow/sdk/execution_time/coordinator.py | 169 +++++++++--
task-sdk/src/airflow/sdk/importers/base.py | 51 +++-
.../task_sdk/coordinators/test_dag_importer.py | 204 +++++++++++++
.../tests/task_sdk/coordinators/test_subprocess.py | 115 +++++++-
.../task_sdk/execution_time/test_coordinator.py | 327 ++++++++++++++++++++-
task-sdk/tests/task_sdk/importers/test_registry.py | 138 +++++++++
10 files changed, 1270 insertions(+), 123 deletions(-)
create mode 100644 task-sdk/src/airflow/sdk/coordinators/_dag_importer.py
create mode 100644 task-sdk/tests/task_sdk/coordinators/test_dag_importer.py