This is an automated email from the ASF dual-hosted git repository.
jason810496 pushed a change to branch jason/java-sdk/native-dag-trigger-dag-run
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit af569b227cd Java SDK: Trigger another Dag's run from a native Java Dag
omit bc815379eb9 Java SDK: Choose one of several tasks with a branch
omit 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
add 4b43050595f Java SDK: Trigger another Dag's run from a native Java Dag
add a8d8d11c734 Java SDK: Point both example triggers at a Dag that
triggers nothing
add 4f263fcfb7b Java SDK: Say why a switch cannot choose a task that
triggers a Dag run
add 5d013803137 Java SDK: Snapshot a TriggerDagRun when its task is
declared
add ddd5fd71fbd Java SDK: Check a TriggerDagRun setting the way every
other config key is checked
add e13fd59e43b Java SDK: Describe what a trigger task pushes and how it
names a run
add 375bef298ff Java SDK: Correct which runtimes already run trigger tasks
add fb0b40b541c Java SDK: Format a trigger task's date-times in one place
add 1cd51bf192b Java SDK: Reject a trigger method that throws a checked
exception
add 7ce837a8fd3 Java SDK: Leave the trigger fixture's logical date to the
Go SDK change
add 08d95210156 Java SDK: Run a trigger task through runTask in tests
add 93f3da61146 Java SDK: Check a trigger task polls the run it started
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 (af569b227cd)
\
N -- N -- N refs/heads/jason/java-sdk/native-dag-trigger-dag-run
(93f3da61146)
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 +-
.../airflow/example/ExampleBundleBuilder.java | 3 +-
.../example/nativedag/AnnotationExample.java | 19 +-
.../example/nativedag/InterfaceExample.java | 10 +-
.../airflow/example/nativedag/TargetExample.java | 49 ++++
.../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 | 111 +++-----
.../kotlin/org/apache/airflow/sdk/BuilderTest.kt | 246 +++++++++--------
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 | 31 +--
.../main/kotlin/org/apache/airflow/sdk/Server.kt | 115 ++++----
.../main/kotlin/org/apache/airflow/sdk/Switch.kt | 240 +++++++++++++++++
.../kotlin/org/apache/airflow/sdk/TaskGroupRef.kt | 22 +-
.../kotlin/org/apache/airflow/sdk/TriggerDagRun.kt | 163 ++++++------
.../org/apache/airflow/sdk/execution/Serde.kt | 15 +-
.../apache/airflow/sdk/execution/TriggerRunner.kt | 14 +-
.../org/apache/airflow/sdk/internal/Fields.kt | 33 +++
.../kotlin/org/apache/airflow/sdk/BranchTest.kt | 175 -------------
.../kotlin/org/apache/airflow/sdk/ClientTest.kt | 5 +-
.../kotlin/org/apache/airflow/sdk/ConditionTest.kt | 83 ++++--
.../kotlin/org/apache/airflow/sdk/ServerTest.kt | 6 +-
.../kotlin/org/apache/airflow/sdk/SwitchTest.kt | 224 ++++++++++++++++
.../org/apache/airflow/sdk/TriggerDagRunTest.kt | 85 ++++++
.../airflow/sdk/conformance/SerializeJava.kt | 130 +++++++--
.../org/apache/airflow/sdk/execution/CommTest.kt | 39 ++-
.../org/apache/airflow/sdk/execution/TaskTest.kt | 107 ++++++--
.../airflow/sdk/execution/TriggerRunnerTest.kt | 43 ++-
.../org/apache/airflow/sdk/internal/RefsTest.kt | 65 +++++
scripts/ci/lang_sdk_serialization/test_dags.yaml | 2 +-
37 files changed, 1511 insertions(+), 1010 deletions(-)
create mode 100644
java-sdk/example/src/java/org/apache/airflow/example/nativedag/TargetExample.java
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
delete mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/BranchTest.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/SwitchTest.kt
