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 a6d4ef08dc6 Apply hook_params to deferred dbt Cloud job runs (#74199)
add 5aa12d3765f Parse native Java Dags and show their source (#74036)
add 74698a57c68 Parse native TypeScript Dags with the Node coordinator
(#74037)
No new revisions were added by this update.
Summary of changes:
.../language-sdks/java.rst | 130 ++++++-
.../language-sdks/typescript.rst | 104 +++++-
.../src/airflow/dag_processing/collection.py | 4 +-
airflow-core/src/airflow/dag_processing/dagbag.py | 10 +-
.../airflow/dag_processing/lang_sdk_processor.py | 22 +-
.../src/airflow/dag_processing/processor.py | 2 +-
.../tests/unit/dag_processing/fake_lang_sdk.py | 2 +-
.../tests/unit/dag_processing/test_collection.py | 2 +-
.../tests/unit/dag_processing/test_dagbag.py | 19 +-
.../unit/dag_processing/test_lang_sdk_processor.py | 21 +-
.../tests/unit/dag_processing/test_manager.py | 2 +-
.../tests/unit/dag_processing/test_processor.py | 4 +-
.../src/airflow/sdk/coordinators/_dag_importer.py | 5 +-
.../src/airflow/sdk/coordinators/_subprocess.py | 158 ++++++++-
.../airflow/sdk/coordinators/java/_dag_importer.py | 122 +++++++
.../airflow/sdk/coordinators/java/_jar_manifest.py | 71 ++++
.../airflow/sdk/coordinators/java/coordinator.py | 163 +++++++--
.../sdk/coordinators/node/_bundle_reader.py | 29 +-
.../airflow/sdk/coordinators/node/_dag_importer.py | 72 ++++
.../airflow/sdk/coordinators/node/coordinator.py | 27 +-
.../src/airflow/sdk/execution_time/coordinator.py | 19 +
.../src/airflow/sdk/execution_time/supervisor.py | 94 ++++-
task-sdk/src/airflow/sdk/importers/base.py | 9 +-
.../src/airflow/sdk/importers/python_importer.py | 4 +-
task-sdk/src/airflow/sdk/importers/zip_importer.py | 4 +-
.../task_sdk/coordinators/java/_jar_test_utils.py | 53 +++
.../task_sdk/coordinators/java/test_coordinator.py | 314 ++++++++++++++++-
.../coordinators/java/test_dag_importer.py | 308 ++++++++++++++++
.../coordinators/java/test_jar_manifest.py | 94 +++++
.../coordinators/node/_bundle_test_utils.py | 5 +
.../coordinators/node/test_bundle_reader.py | 10 +-
.../task_sdk/coordinators/node/test_coordinator.py | 114 +++++-
.../coordinators/node/test_dag_importer.py | 275 +++++++++++++++
.../task_sdk/coordinators/test_dag_importer.py | 2 +-
.../tests/task_sdk/coordinators/test_subprocess.py | 387 ++++++++++++++++++++-
.../task_sdk/execution_time/test_supervisor.py | 256 ++++++++++++++
36 files changed, 2799 insertions(+), 118 deletions(-)
create mode 100644 task-sdk/src/airflow/sdk/coordinators/java/_dag_importer.py
create mode 100644 task-sdk/src/airflow/sdk/coordinators/java/_jar_manifest.py
create mode 100644 task-sdk/src/airflow/sdk/coordinators/node/_dag_importer.py
create mode 100644 task-sdk/tests/task_sdk/coordinators/java/_jar_test_utils.py
create mode 100644
task-sdk/tests/task_sdk/coordinators/java/test_dag_importer.py
create mode 100644
task-sdk/tests/task_sdk/coordinators/java/test_jar_manifest.py
create mode 100644
task-sdk/tests/task_sdk/coordinators/node/test_dag_importer.py
