This is an automated email from the ASF dual-hosted git repository.
jason810496 pushed a change to branch jason/java-sdk/pack-dag-sources
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 7c5001f627f Java SDK: Pack each native Dag's source file into the
bundle JAR
omit 2e38a8cf2dc Java SDK: Record the class that declares each Dag and
describe it on request
omit a1c826eefc3 Java SDK: Check native Dag serialization against Airflow's
omit ad6c51a5179 Java SDK: Write each Dag tag once, as Python does
omit 3e25da5c719 Java SDK: Serialize a native Dag's task groups
omit 011b248e26b Java SDK: Leave out the email flags a Java task cannot act
on
omit 4e41209eb68 Java SDK: Leave config-backed Dag fields for Airflow to
fill in
omit 8612ff72cdb Test that the conformance check compares Dag params
omit e41b8613d25 Java SDK: Serialize native Dags to DagSerialization v3 on
parse requests
omit 81e6d36f676 Java SDK: Group a native Dag's tasks with task groups
add 94121920f24 Java SDK: Group a native Dag's tasks with task groups
add 428b1f57b64 Java SDK: Serialize native Dags to DagSerialization v3 on
parse requests
add f32a818cedc Test that the conformance check compares Dag params
add e14840a9cfd Java SDK: Leave config-backed Dag fields for Airflow to
fill in
add 33220b8febb Java SDK: Leave out the email flags a Java task cannot act
on
add 4394011d1c5 Java SDK: Serialize a native Dag's task groups
add 0385b2df2e0 Java SDK: Write each Dag tag once, as Python does
add b0eed7b7d6a Java SDK: Check native Dag serialization against Airflow's
add e610db96ac0 Java SDK: Run the serialization conformance check on every
file that steers it
add 5193fdd18ce Java SDK: Build a native Dag's timetable the way Python
does
add 2098a2ac07a Java SDK: Carry a native Dag's call arguments as argument
bindings
add 6d395128737 Java SDK: Keep one unserializable Dag from failing a whole
bundle's parse
add efba9d23aee Java SDK: Mark the native Dag capabilities as shipping in
3.4
add 2e3fb8978fa Java SDK: Record the class that declares each Dag and
describe it on request
add 05c4e438c39 Java SDK: Pack each native Dag's source file into the
bundle JAR
add 6a60451db67 Java SDK: Bound the describe run and keep its payload to
the bundle JAR
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (7c5001f627f)
\
N -- N -- N refs/heads/jason/java-sdk/pack-dag-sources
(6a60451db67)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.pre-commit-config.yaml | 4 +-
.../language-sdks/java.rst | 4 +-
java-sdk/README.md | 8 +-
java-sdk/capabilities.yaml | 8 +-
.../apache/airflow/sdk/plugin/AirflowSdkPlugin.kt | 10 +-
.../apache/airflow/sdk/plugin/PackDagSources.kt | 62 ++++---
.../airflow/sdk/plugin/AirflowSdkPluginTest.kt | 23 +++
.../org/apache/airflow/sdk/BuilderProcessor.kt | 65 ++++++--
.../kotlin/org/apache/airflow/sdk/BuilderTest.kt | 156 +++++++++++++++++-
.../ci/prek/check_serialization_conformance.py | 21 ++-
java-sdk/sdk/module.md | 8 +-
.../main/kotlin/org/apache/airflow/sdk/DagDef.kt | 85 ++++++----
.../src/main/kotlin/org/apache/airflow/sdk/Deps.kt | 33 +++-
.../main/kotlin/org/apache/airflow/sdk/Server.kt | 6 +
.../kotlin/org/apache/airflow/sdk/TaskGroupRef.kt | 4 +-
.../org/apache/airflow/sdk/execution/Serde.kt | 181 ++++++++++++++++++---
.../org/apache/airflow/sdk/internal/ArgValues.kt | 24 +--
.../kotlin/org/apache/airflow/sdk/internal/Refs.kt | 22 +++
.../org/apache/airflow/sdk/internal/TaskArgs.kt | 2 +-
.../kotlin/org/apache/airflow/sdk/TaskGroupTest.kt | 67 ++++++++
.../org/apache/airflow/sdk/execution/SerdeTest.kt | 109 ++++++++++++-
21 files changed, 771 insertions(+), 131 deletions(-)
