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 70bc47c859d Explain how to rebuild provider packages with the release
manager's flit (#73699)
add 9876a4b469d Java SDK: Honor TaskFlow arg bindings sent by the
supervisor (#71188)
No new revisions were added by this update.
Summary of changes:
.../language-sdks/java.rst | 244 ++++++---
.../java_sdk_tests/test_java_sdk_dag.py | 52 +-
java-sdk/README.md | 2 +-
java-sdk/adr/0001-mixed-lang-dag-interface.md | 33 +-
java-sdk/adr/0002-native-dag-interface.md | 2 +-
java-sdk/capabilities.yaml | 2 +-
.../apache/airflow/example/AnnotationExample.java | 32 +-
.../airflow/example/ExampleBundleBuilder.java | 19 +-
.../airflow/example/InterfaceExampleBuilder.java | 38 +-
.../apache/airflow/example/XComCastingExample.java | 39 +-
.../example/src/resources/dags/java_examples.py | 46 +-
java-sdk/gradle.properties | 2 +-
.../org/apache/airflow/sdk/BuilderProcessor.kt | 366 +++++++++----
.../kotlin/org/apache/airflow/sdk/BuilderTest.kt | 595 +++++++++++++++++++--
java-sdk/sdk/build.gradle.kts | 8 +-
java-sdk/sdk/module.md | 2 +-
java-sdk/sdk/schema/schema.json | 259 ++++++++-
.../kotlin/org/apache/airflow/sdk/ArgName.kt} | 49 +-
.../main/kotlin/org/apache/airflow/sdk/Builder.kt | 33 +-
.../main/kotlin/org/apache/airflow/sdk/Bundle.kt | 122 ++++-
.../main/kotlin/org/apache/airflow/sdk/Client.kt | 39 +-
.../main/kotlin/org/apache/airflow/sdk/DagDef.kt | 12 +
.../kotlin/org/apache/airflow/sdk/InputTask.kt | 88 +++
.../main/kotlin/org/apache/airflow/sdk/Server.kt | 1 +
.../kotlin/org/apache/airflow/sdk/TaskInput.kt | 60 +++
.../org/apache/airflow/sdk/execution/ArgBinding.kt | 90 ++++
.../org/apache/airflow/sdk/execution/Task.kt | 2 +-
.../org/apache/airflow/sdk/internal/ArgValues.kt | 294 ++++++++++
.../org/apache/airflow/sdk/internal/InputTypes.kt | 176 ++++++
.../org/apache/airflow/sdk/internal/Registrar.kt | 22 +-
.../org/apache/airflow/sdk/internal/TaskArgs.kt | 142 +++++
.../org/apache/airflow/sdk/internal/TypeRef.kt | 47 ++
.../org/apache/airflow/sdk/ArgTestSupport.kt | 96 ++++
.../kotlin/org/apache/airflow/sdk/ArgValuesTest.kt | 303 +++++++++++
.../kotlin/org/apache/airflow/sdk/BundleTest.kt | 136 +++++
.../kotlin/org/apache/airflow/sdk/InputTaskTest.kt | 167 ++++++
.../kotlin/org/apache/airflow/sdk/TaskArgsTest.kt | 336 ++++++++++++
37 files changed, 3630 insertions(+), 326 deletions(-)
copy java-sdk/sdk/src/{test/kotlin/org/apache/airflow/sdk/BundleTest.kt =>
main/kotlin/org/apache/airflow/sdk/ArgName.kt} (50%)
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/InputTask.kt
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/TaskInput.kt
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/execution/ArgBinding.kt
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/internal/ArgValues.kt
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/internal/InputTypes.kt
copy airflow-core/src/airflow/ui/tests/e2e/fixtures/index.ts =>
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/internal/Registrar.kt (58%)
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/internal/TaskArgs.kt
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/internal/TypeRef.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/ArgTestSupport.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/ArgValuesTest.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/InputTaskTest.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/TaskArgsTest.kt
