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 6e5d9ddc185 Update the TypeScript SDK docs for Dags declared in
TypeScript (#73875)
new 2bda1928703 Java SDK: Pack each native Dag's source file into the
bundle JAR (#74096)
new d4013cc2b5b Java SDK: Pick one of two tasks with a condition (#74438)
new c3043c266c6 Java SDK: Choose one of several tasks with a branch
(#74439)
new c5f504366d5 Java SDK: Trigger another Dag's run from a native Java Dag
(#74440)
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.pre-commit-config.yaml | 2 +-
.../0015-per-dag-source-in-bundle-artifact.md | 2 +
.../language-sdks/java.rst | 4 +
java-sdk/README.md | 10 +-
java-sdk/capabilities.yaml | 18 +-
.../airflow/example/ExampleBundleBuilder.java | 3 +-
.../example/nativedag/AnnotationExample.java | 44 +-
.../example/nativedag/InterfaceExample.java | 57 +-
.../airflow/example/nativedag/TargetExample.java | 49 ++
java-sdk/plugin/build.gradle.kts | 6 +
.../apache/airflow/sdk/plugin/AirflowSdkPlugin.kt | 55 +-
.../org/apache/airflow/sdk/plugin/ClassFiles.kt | 85 +++
.../apache/airflow/sdk/plugin/PackDagSources.kt | 256 ++++++++
.../airflow/sdk/plugin/AirflowSdkPluginTest.kt | 365 +++++++++++
.../apache/airflow/sdk/plugin/ClassFilesTest.kt | 80 +++
.../airflow/sdk/plugin/PackDagSourcesTest.kt | 89 +++
.../org/apache/airflow/sdk/plugin/TestSupport.kt} | 38 +-
.../org/apache/airflow/sdk/BuilderProcessor.kt | 209 ++++++-
.../kotlin/org/apache/airflow/sdk/BuilderTest.kt | 692 ++++++++++++++++++++-
.../ci/prek/check_serialization_conformance.py | 2 +-
java-sdk/sdk/build.gradle.kts | 68 ++
java-sdk/sdk/module.md | 6 +-
.../main/kotlin/org/apache/airflow/sdk/Bundle.kt | 27 +-
.../kotlin/org/apache/airflow/sdk/Condition.kt | 224 +++++++
.../main/kotlin/org/apache/airflow/sdk/DagDef.kt | 140 +++++
.../main/kotlin/org/apache/airflow/sdk/Decider.kt | 90 +++
.../main/kotlin/org/apache/airflow/sdk/Server.kt | 109 +++-
.../main/kotlin/org/apache/airflow/sdk/Switch.kt | 240 +++++++
.../kotlin/org/apache/airflow/sdk/TaskGroupRef.kt | 81 +++
.../kotlin/org/apache/airflow/sdk/TriggerDagRun.kt | 189 ++++++
.../org/apache/airflow/sdk/execution/Client.kt | 88 +++
.../org/apache/airflow/sdk/execution/Logger.kt | 5 +
.../org/apache/airflow/sdk/execution/Serde.kt | 129 +++-
.../org/apache/airflow/sdk/execution/Task.kt | 42 +-
.../apache/airflow/sdk/execution/TriggerRunner.kt | 324 ++++++++++
.../org/apache/airflow/sdk/internal/DagSource.kt | 66 ++
.../org/apache/airflow/sdk/internal/Fields.kt | 33 +
.../kotlin/org/apache/airflow/sdk/internal/Ids.kt | 10 +
.../apache/airflow/example/DagSourceFixtures.kt} | 49 +-
.../org/apache/airflow/sdk/ArgTestSupport.kt | 19 +
.../kotlin/org/apache/airflow/sdk/ClientTest.kt | 19 +
.../kotlin/org/apache/airflow/sdk/ConditionTest.kt | 208 +++++++
.../kotlin/org/apache/airflow/sdk/DagSourceTest.kt | 132 ++++
.../kotlin/org/apache/airflow/sdk/ServerTest.kt | 6 +-
.../kotlin/org/apache/airflow/sdk/SwitchTest.kt | 224 +++++++
.../org/apache/airflow/sdk/TriggerDagRunTest.kt | 275 ++++++++
.../airflow/sdk/conformance/SerializeJava.kt | 191 +++++-
.../org/apache/airflow/sdk/execution/CommTest.kt | 171 +++++
.../org/apache/airflow/sdk/execution/TaskTest.kt | 319 ++++++++++
.../airflow/sdk/execution/TriggerRunnerTest.kt | 473 ++++++++++++++
.../apache/airflow/sdk/internal/ArgValuesTest.kt | 19 +
.../org/apache/airflow/sdk/internal/RefsTest.kt | 65 ++
scripts/ci/lang_sdk_serialization/test_dags.yaml | 5 +-
.../airflow/sdk/coordinators/java/_dag_importer.py | 4 +-
.../coordinators/java/test_dag_importer.py | 19 +
55 files changed, 5967 insertions(+), 168 deletions(-)
create mode 100644
java-sdk/example/src/java/org/apache/airflow/example/nativedag/TargetExample.java
create mode 100644
java-sdk/plugin/src/main/kotlin/org/apache/airflow/sdk/plugin/ClassFiles.kt
create mode 100644
java-sdk/plugin/src/main/kotlin/org/apache/airflow/sdk/plugin/PackDagSources.kt
create mode 100644
java-sdk/plugin/src/test/kotlin/org/apache/airflow/sdk/plugin/AirflowSdkPluginTest.kt
create mode 100644
java-sdk/plugin/src/test/kotlin/org/apache/airflow/sdk/plugin/ClassFilesTest.kt
create mode 100644
java-sdk/plugin/src/test/kotlin/org/apache/airflow/sdk/plugin/PackDagSourcesTest.kt
copy
java-sdk/{example/src/java/org/apache/airflow/example/ExampleBundleBuilder.java
=> plugin/src/test/kotlin/org/apache/airflow/sdk/plugin/TestSupport.kt} (50%)
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/Condition.kt
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/Decider.kt
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/Switch.kt
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/TriggerDagRun.kt
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/execution/TriggerRunner.kt
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/internal/DagSource.kt
copy
java-sdk/sdk/src/{testFixtures/kotlin/org/apache/airflow/sdk/execution/LogCapture.kt
=> test/kotlin/org/apache/airflow/example/DagSourceFixtures.kt} (57%)
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/ConditionTest.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/DagSourceTest.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/SwitchTest.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/TriggerDagRunTest.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/execution/TriggerRunnerTest.kt
