This is an automated email from the ASF dual-hosted git repository.
jason810496 pushed a change to branch jason/java-sdk/native-dag-branch
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard bc815379eb9 Java SDK: Choose one of several tasks with a branch
discard 30e5218ddeb Java SDK: Pick one of two tasks with a condition
add b18c0aa45c9 Java SDK: Use a describe run's output even when the run
itself failed
add 88934351785 Java SDK: Serve and describe sources from their own Server
classes
add 62dd96e93bb Java SDK: Pack the sources into the one JAR the bundle is
built from
add cb3dc2d48f2 Java SDK: Attach the plugin's documentation to the plugin
class
add ba08f8e4fab Java SDK: Drop the duplicated classes dir from the
describe classpath
add a073f81ca68 Java SDK: Let a bundle set how long the describe run may
take
add 063ab7ecba6 Java SDK: Pick one of two tasks with a condition
add ec0c071cd3f Java SDK: Let a wiring view name a condition's sides in
more than one call
add 41ac9d3ca0d Java SDK: Reject a decider class registered as an ordinary
task
add 5b57b301175 Java SDK: Name a condition's sides Then and Else
add f118e9e22d8 Java SDK: Pin the order a condition skips and records what
it skipped
add dbe29e41a1f Java SDK: Drop the unused switch in the condition test's
decider
add f3c2472e244 Java SDK: Choose one of several tasks with a branch
add 2594c90237e Java SDK: Name the multi-way branch Switch, as the other
SDKs do
add 141e5cedb9c Java SDK: Name a switch case by its task class in both
styles
add 35fd6f24a51 Java SDK: Say when a switch rejects a choice and when it
fails
add 08909559642 Java SDK: Cover a generated switch that names a task it
cannot choose
add b10b0dc0595 Java SDK: Check a switch carries the chosen task's id
add e643f06dc68 Java SDK: Let a wiring view name a switch's cases in more
than one call
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 (bc815379eb9)
\
N -- N -- N refs/heads/jason/java-sdk/native-dag-branch
(e643f06dc68)
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 | 2 +-
java-sdk/README.md | 2 +-
java-sdk/capabilities.yaml | 2 +-
.../example/nativedag/AnnotationExample.java | 17 +-
.../example/nativedag/InterfaceExample.java | 8 +-
.../apache/airflow/sdk/plugin/AirflowSdkPlugin.kt | 32 ++-
.../apache/airflow/sdk/plugin/PackDagSources.kt | 44 +++-
.../airflow/sdk/plugin/AirflowSdkPluginTest.kt | 32 +++
.../org/apache/airflow/sdk/BuilderProcessor.kt | 102 ++------
.../kotlin/org/apache/airflow/sdk/BuilderTest.kt | 213 ++++++++-------
java-sdk/sdk/build.gradle.kts | 22 +-
java-sdk/sdk/module.md | 2 +-
.../main/kotlin/org/apache/airflow/sdk/Branch.kt | 291 ---------------------
.../main/kotlin/org/apache/airflow/sdk/Bundle.kt | 17 +-
.../kotlin/org/apache/airflow/sdk/Condition.kt | 40 +--
.../main/kotlin/org/apache/airflow/sdk/DagDef.kt | 26 +-
.../main/kotlin/org/apache/airflow/sdk/Server.kt | 115 ++++----
.../main/kotlin/org/apache/airflow/sdk/Switch.kt | 234 +++++++++++++++++
.../kotlin/org/apache/airflow/sdk/TaskGroupRef.kt | 22 +-
.../kotlin/org/apache/airflow/sdk/ClientTest.kt | 5 +-
.../kotlin/org/apache/airflow/sdk/ConditionTest.kt | 83 ++++--
.../kotlin/org/apache/airflow/sdk/ServerTest.kt | 6 +-
.../airflow/sdk/{BranchTest.kt => SwitchTest.kt} | 124 +++++----
.../airflow/sdk/conformance/SerializeJava.kt | 127 ++++++++-
.../org/apache/airflow/sdk/execution/CommTest.kt | 27 ++
.../org/apache/airflow/sdk/execution/TaskTest.kt | 68 +++--
.../org/apache/airflow/sdk/internal/RefsTest.kt | 65 +++++
27 files changed, 975 insertions(+), 753 deletions(-)
delete mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/Branch.kt
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/Switch.kt
rename java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/{BranchTest.kt =>
SwitchTest.kt} (53%)
