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 76bf88a4877 API: Translate domain ValueError in Task State Store route
(#73753)
add 1a67bf46b55 Support DagBundle based deployment for Coordinator (#70805)
No new revisions were added by this update.
Summary of changes:
.../authoring-and-scheduling/language-sdks/go.rst | 22 +-
.../language-sdks/java.rst | 30 ++-
.../language-sdks/typescript.rst | 22 +-
.../src/airflow/dag_processing/bundles/manager.py | 40 +++-
airflow-core/tests/integration/otel/test_otel.py | 2 +-
.../bundles/test_dag_bundle_manager.py | 86 ++++---
contributing-docs/30_new_language_sdk.rst | 6 +
devel-common/src/tests_common/pytest_plugin.py | 26 ++
devel-common/src/tests_common/test_utils/config.py | 13 +
generated/known_airflow_exceptions.txt | 2 +-
.../airflow/sdk/coordinators/_bundle_metadata.py | 28 ++-
.../src/airflow/sdk/coordinators/_subprocess.py | 211 ++++++++++++++--
.../sdk/coordinators/executable/coordinator.py | 17 +-
.../airflow/sdk/coordinators/java/coordinator.py | 24 +-
.../airflow/sdk/coordinators/node/coordinator.py | 21 +-
task-sdk/src/airflow/sdk/execution_time/bundles.py | 90 +++++++
.../src/airflow/sdk/execution_time/task_runner.py | 83 +------
task-sdk/src/airflow/sdk/execution_time/tracing.py | 60 +++++
.../coordinators/executable/test_coordinator.py | 60 ++++-
.../task_sdk/coordinators/java/test_coordinator.py | 39 +++
.../task_sdk/coordinators/node/test_coordinator.py | 51 +++-
.../tests/task_sdk/coordinators/test_subprocess.py | 264 ++++++++++++++++++++-
.../tests/task_sdk/execution_time/test_bundles.py | 86 +++++++
.../task_sdk/execution_time/test_task_runner.py | 171 +------------
.../tests/task_sdk/execution_time/test_tracing.py | 144 +++++++++++
25 files changed, 1251 insertions(+), 347 deletions(-)
create mode 100644 task-sdk/src/airflow/sdk/execution_time/bundles.py
create mode 100644 task-sdk/src/airflow/sdk/execution_time/tracing.py
create mode 100644 task-sdk/tests/task_sdk/execution_time/test_bundles.py
create mode 100644 task-sdk/tests/task_sdk/execution_time/test_tracing.py
