This is an automated email from the ASF dual-hosted git repository.
shahar1 pushed a commit to branch v3-4-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-4-test by this push:
new 3e7f5c8a7cd [v3-4-test] Release the Java SDK 1.0.0 and pin its schema
URL to the published docs site (#75944) (#76577)
3e7f5c8a7cd is described below
commit 3e7f5c8a7cd499779c7544bb56e3ff3aba7c3e32
Author: Jason(Zhe-You) Liu <[email protected]>
AuthorDate: Fri Nov 6 16:53:52 2026 +0800
[v3-4-test] Release the Java SDK 1.0.0 and pin its schema URL to the
published docs site (#75944) (#76577)
* [v3-4-test] Bump Java SDK to 1.0.0
Sets the version for the Java SDK 1.0.0 release candidate. The e2e and k8s
test bundles resolve the SDK from mavenLocal by this version, so they move with
it.
* Refresh the Java SDK supervisor schema from the published docs site
The staged site is a preview of the in-progress docs build, not a release
artifact. A released SDK should take its schema from the published location.
* Drop the experimental badge from the Java SDK and language SDK docs
The Java SDK goes GA with 1.0.0, so its docs should stop marking it
experimental.
* [v3-4-test] Refresh the Java SDK supervisor schema
The vendored schema predates later changes under api_version 2026-10-30,
and the version-gated sync only refreshes it when that version changes, so Java
SDK 1.0.0 would otherwise ship without the messages Airflow 3.4.0 sends.
---
.../language-sdks/index.rst | 2 -
.../language-sdks/java.rst | 2 -
.../java-native-bundle/gradle.properties | 2 +-
.../java-test-bundle/gradle.properties | 2 +-
java-sdk/gradle.properties | 2 +-
java-sdk/sdk/build.gradle.kts | 2 +-
java-sdk/sdk/schema/schema.json | 853 ++++++++++++++-------
.../lang_sdk/java_example/gradle.properties | 2 +-
8 files changed, 591 insertions(+), 276 deletions(-)
diff --git a/airflow-core/docs/authoring-and-scheduling/language-sdks/index.rst
b/airflow-core/docs/authoring-and-scheduling/language-sdks/index.rst
index ea8d4b8448d..d5816f1fef5 100644
--- a/airflow-core/docs/authoring-and-scheduling/language-sdks/index.rst
+++ b/airflow-core/docs/authoring-and-scheduling/language-sdks/index.rst
@@ -20,8 +20,6 @@
Non-Python Task SDKs
====================
-|experimental|
-
Airflow Dags and tasks can be written in languages other than Python. A
language SDK is used in one of two
ways:
diff --git a/airflow-core/docs/authoring-and-scheduling/language-sdks/java.rst
b/airflow-core/docs/authoring-and-scheduling/language-sdks/java.rst
index 0cc9981b52d..e0070b701b0 100644
--- a/airflow-core/docs/authoring-and-scheduling/language-sdks/java.rst
+++ b/airflow-core/docs/authoring-and-scheduling/language-sdks/java.rst
@@ -20,8 +20,6 @@
Java SDK
========
-|experimental|
-
The Java SDK lets you write Airflow Dags and tasks in Java, Kotlin, Scala or
any other JVM language. There are
two ways to use it:
diff --git a/airflow-e2e-tests/java-native-bundle/gradle.properties
b/airflow-e2e-tests/java-native-bundle/gradle.properties
index c3c94e0057f..578019da742 100644
--- a/airflow-e2e-tests/java-native-bundle/gradle.properties
+++ b/airflow-e2e-tests/java-native-bundle/gradle.properties
@@ -17,4 +17,4 @@
org.gradle.configuration-cache=true
-projectVersion=1.0.0-SNAPSHOT
+projectVersion=1.0.0
diff --git a/airflow-e2e-tests/java-test-bundle/gradle.properties
b/airflow-e2e-tests/java-test-bundle/gradle.properties
index c3c94e0057f..578019da742 100644
--- a/airflow-e2e-tests/java-test-bundle/gradle.properties
+++ b/airflow-e2e-tests/java-test-bundle/gradle.properties
@@ -17,4 +17,4 @@
org.gradle.configuration-cache=true
-projectVersion=1.0.0-SNAPSHOT
+projectVersion=1.0.0
diff --git a/java-sdk/gradle.properties b/java-sdk/gradle.properties
index 477b31da386..5d0d0e61ef6 100644
--- a/java-sdk/gradle.properties
+++ b/java-sdk/gradle.properties
@@ -19,6 +19,6 @@ org.gradle.configuration-cache=true
airflowSupervisorSchemaVersion=2026-10-30
-projectVersion=1.0.0-SNAPSHOT
+projectVersion=1.0.0
mockkVersion=1.13.12
diff --git a/java-sdk/sdk/build.gradle.kts b/java-sdk/sdk/build.gradle.kts
index 09d626e68f6..539ac8e88d1 100644
--- a/java-sdk/sdk/build.gradle.kts
+++ b/java-sdk/sdk/build.gradle.kts
@@ -38,7 +38,7 @@ plugins {
kotlin("plugin.serialization") version "2.4.20"
}
-val schemaBaseUrl =
"https://airflow.staged.apache.org/schemas/supervisor-schema";
+val schemaBaseUrl = "https://airflow.apache.org/schemas/supervisor-schema";
val schemaInput = layout.projectDirectory.file("schema/schema.json")
val pointersDir = layout.buildDirectory.dir("schema-pointers/main")
val jsonSchemaPackage = "org.apache.airflow.sdk.execution.comm"
diff --git a/java-sdk/sdk/schema/schema.json b/java-sdk/sdk/schema/schema.json
index b671959c50a..e739708d12d 100644
--- a/java-sdk/sdk/schema/schema.json
+++ b/java-sdk/sdk/schema/schema.json
@@ -34,7 +34,14 @@
"anyOf": [
{
"additionalProperties": {
- "$ref": "#/$defs/JsonValue"
+ "anyOf": [
+ {
+ "$ref": "#/$defs/JsonValue"
+ },
+ {
+ "type": "null"
+ }
+ ]
},
"type": "object"
},
@@ -187,34 +194,6 @@
"title": "AssetProfile",
"type": "object"
},
- "AssetReferenceAssetEventDagRun": {
- "additionalProperties": false,
- "description": "Schema for AssetModel used in
AssetEventDagRunReference.",
- "properties": {
- "name": {
- "title": "Name",
- "type": "string"
- },
- "uri": {
- "title": "Uri",
- "type": "string"
- },
- "extra": {
- "additionalProperties": {
- "$ref": "#/$defs/JsonValue"
- },
- "title": "Extra",
- "type": "object"
- }
- },
- "required": [
- "name",
- "uri",
- "extra"
- ],
- "title": "AssetReferenceAssetEventDagRun",
- "type": "object"
- },
"AssetResponse": {
"description": "Asset schema for responses with fields that are needed
for Runtime.",
"properties": {
@@ -234,7 +213,14 @@
"anyOf": [
{
"additionalProperties": {
- "$ref": "#/$defs/JsonValue"
+ "anyOf": [
+ {
+ "$ref": "#/$defs/JsonValue"
+ },
+ {
+ "type": "null"
+ }
+ ]
},
"type": "object"
},
@@ -273,7 +259,14 @@
"anyOf": [
{
"additionalProperties": {
- "$ref": "#/$defs/JsonValue"
+ "anyOf": [
+ {
+ "$ref": "#/$defs/JsonValue"
+ },
+ {
+ "type": "null"
+ }
+ ]
},
"type": "object"
},
@@ -304,7 +297,14 @@
"description": "Response to GetAssetStateStore; wraps the generated API
response for supervisor to worker comms.",
"properties": {
"value": {
- "$ref": "#/$defs/JsonValue"
+ "anyOf": [
+ {
+ "$ref": "#/$defs/JsonValue"
+ },
+ {
+ "type": "null"
+ }
+ ]
},
"type": {
"const": "AssetStateStoreResult",
@@ -347,17 +347,10 @@
"description": "Park a task instance awaiting human input
(Human-in-the-loop), without a trigger.",
"properties": {
"state": {
- "anyOf": [
- {
- "const": "awaiting_input",
- "type": "string"
- },
- {
- "type": "null"
- }
- ],
+ "const": "awaiting_input",
"default": "awaiting_input",
- "title": "State"
+ "title": "State",
+ "type": "string"
},
"timeout": {
"anyOf": [
@@ -380,7 +373,14 @@
"anyOf": [
{
"additionalProperties": {
- "$ref": "#/$defs/JsonValue"
+ "anyOf": [
+ {
+ "$ref": "#/$defs/JsonValue"
+ },
+ {
+ "type": "null"
+ }
+ ]
},
"type": "object"
},
@@ -513,6 +513,97 @@
"title": "ClearTaskStateStore",
"type": "object"
},
+ "ConnectionResponse": {
+ "description": "Connection schema for responses with fields that are
needed for Runtime.",
+ "properties": {
+ "conn_id": {
+ "title": "Conn Id",
+ "type": "string"
+ },
+ "conn_type": {
+ "title": "Conn Type",
+ "type": "string"
+ },
+ "host": {
+ "anyOf": [
+ {
+ "type": "string"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "title": "Host"
+ },
+ "schema": {
+ "anyOf": [
+ {
+ "type": "string"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "title": "Schema"
+ },
+ "login": {
+ "anyOf": [
+ {
+ "type": "string"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "title": "Login"
+ },
+ "password": {
+ "anyOf": [
+ {
+ "type": "string"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "title": "Password"
+ },
+ "port": {
+ "anyOf": [
+ {
+ "type": "integer"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "title": "Port"
+ },
+ "extra": {
+ "anyOf": [
+ {
+ "type": "string"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "title": "Extra"
+ }
+ },
+ "required": [
+ "conn_id",
+ "conn_type",
+ "host",
+ "schema",
+ "login",
+ "password",
+ "port",
+ "extra"
+ ],
+ "title": "ConnectionResponse",
+ "type": "object"
+ },
"ConnectionResult": {
"properties": {
"conn_id": {
@@ -532,7 +623,6 @@
"type": "null"
}
],
- "default": null,
"title": "Host"
},
"schema": {
@@ -544,7 +634,6 @@
"type": "null"
}
],
- "default": null,
"title": "Schema"
},
"login": {
@@ -556,7 +645,6 @@
"type": "null"
}
],
- "default": null,
"title": "Login"
},
"password": {
@@ -568,7 +656,6 @@
"type": "null"
}
],
- "default": null,
"title": "Password"
},
"port": {
@@ -580,7 +667,6 @@
"type": "null"
}
],
- "default": null,
"title": "Port"
},
"extra": {
@@ -592,7 +678,6 @@
"type": "null"
}
],
- "default": null,
"title": "Extra"
},
"type": {
@@ -604,7 +689,13 @@
},
"required": [
"conn_id",
- "conn_type"
+ "conn_type",
+ "host",
+ "schema",
+ "login",
+ "password",
+ "port",
+ "extra"
],
"title": "ConnectionResult",
"type": "object"
@@ -924,6 +1015,20 @@
"default": null,
"title": "Import Errors"
},
+ "parsed_definitions": {
+ "items": {
+ "type": "string"
+ },
+ "title": "Parsed Definitions",
+ "type": "array"
+ },
+ "dag_source_codes": {
+ "additionalProperties": {
+ "$ref": "#/$defs/DagSourceCode"
+ },
+ "title": "Dag Source Codes",
+ "type": "object"
+ },
"type": {
"const": "DagFileParsingResult",
"default": "DagFileParsingResult",
@@ -957,7 +1062,6 @@
"type": "null"
}
],
- "default": null,
"title": "Bundle Name"
},
"bundle_version": {
@@ -969,7 +1073,6 @@
"type": "null"
}
],
- "default": null,
"title": "Bundle Version"
},
"relative_fileloc": {
@@ -981,7 +1084,6 @@
"type": "null"
}
],
- "default": null,
"title": "Relative Fileloc"
},
"owners": {
@@ -993,7 +1095,6 @@
"type": "null"
}
],
- "default": null,
"title": "Owners"
},
"tags": {
@@ -1013,7 +1114,6 @@
"type": "null"
}
],
- "default": null,
"title": "Next Dagrun"
},
"type": {
@@ -1026,7 +1126,12 @@
"required": [
"dag_id",
"is_paused",
- "tags"
+ "bundle_name",
+ "bundle_version",
+ "relative_fileloc",
+ "owners",
+ "tags",
+ "next_dagrun"
],
"title": "DagResult",
"type": "object"
@@ -1053,13 +1158,19 @@
"type": "null"
}
],
- "default": null,
"title": "Logical Date"
},
"start_date": {
- "format": "date-time",
- "title": "Start Date",
- "type": "string"
+ "anyOf": [
+ {
+ "format": "date-time",
+ "type": "string"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "title": "Start Date"
},
"end_date": {
"anyOf": [
@@ -1071,7 +1182,6 @@
"type": "null"
}
],
- "default": null,
"title": "End Date"
},
"state": {
@@ -1088,7 +1198,6 @@
"type": "null"
}
],
- "default": null,
"title": "Data Interval Start"
},
"data_interval_end": {
@@ -1101,7 +1210,6 @@
"type": "null"
}
],
- "default": null,
"title": "Data Interval End"
},
"partition_key": {
@@ -1113,15 +1221,19 @@
"type": "null"
}
],
- "default": null,
"title": "Partition Key"
}
},
"required": [
"run_id",
"dag_id",
+ "logical_date",
"start_date",
- "state"
+ "end_date",
+ "state",
+ "data_interval_start",
+ "data_interval_end",
+ "partition_key"
],
"title": "DagRunAssetReference",
"type": "object"
@@ -1176,7 +1288,6 @@
"type": "null"
}
],
- "default": null,
"title": "Logical Date"
},
"data_interval_start": {
@@ -1189,7 +1300,6 @@
"type": "null"
}
],
- "default": null,
"title": "Data Interval Start"
},
"data_interval_end": {
@@ -1202,7 +1312,6 @@
"type": "null"
}
],
- "default": null,
"title": "Data Interval End"
},
"run_after": {
@@ -1220,7 +1329,6 @@
"type": "null"
}
],
- "default": null,
"title": "Start Date"
},
"end_date": {
@@ -1233,7 +1341,6 @@
"type": "null"
}
],
- "default": null,
"title": "End Date"
},
"clear_number": {
@@ -1295,7 +1402,6 @@
"type": "null"
}
],
- "default": null,
"title": "Partition Key"
},
"partition_date": {
@@ -1345,10 +1451,16 @@
"required": [
"dag_id",
"run_id",
+ "logical_date",
+ "data_interval_start",
+ "data_interval_end",
"run_after",
+ "start_date",
+ "end_date",
"run_type",
"state",
- "consumed_asset_events"
+ "consumed_asset_events",
+ "partition_key"
],
"title": "DagRunResult",
"type": "object"
@@ -1395,22 +1507,34 @@
"title": "DagRunType",
"type": "string"
},
+ "DagSourceCode": {
+ "description": "Raw source code and its language identifier for a DAG
definition.",
+ "properties": {
+ "source_code": {
+ "title": "Source Code",
+ "type": "string"
+ },
+ "language": {
+ "title": "Language",
+ "type": "string"
+ }
+ },
+ "required": [
+ "source_code",
+ "language"
+ ],
+ "title": "DagSourceCode",
+ "type": "object"
+ },
"DeferTask": {
"additionalProperties": false,
"description": "Update a task instance state to deferred.",
"properties": {
"state": {
- "anyOf": [
- {
- "const": "deferred",
- "type": "string"
- },
- {
- "type": "null"
- }
- ],
+ "const": "deferred",
"default": "deferred",
- "title": "State"
+ "title": "State",
+ "type": "string"
},
"classpath": {
"title": "Classpath",
@@ -1420,7 +1544,14 @@
"anyOf": [
{
"additionalProperties": {
- "$ref": "#/$defs/JsonValue"
+ "anyOf": [
+ {
+ "$ref": "#/$defs/JsonValue"
+ },
+ {
+ "type": "null"
+ }
+ ]
},
"type": "object"
},
@@ -1467,7 +1598,14 @@
"anyOf": [
{
"additionalProperties": {
- "$ref": "#/$defs/JsonValue"
+ "anyOf": [
+ {
+ "$ref": "#/$defs/JsonValue"
+ },
+ {
+ "type": "null"
+ }
+ ]
},
"type": "object"
},
@@ -2698,6 +2836,11 @@
},
"GetXCom": {
"properties": {
+ "previous_iteration": {
+ "default": false,
+ "title": "Previous Iteration",
+ "type": "boolean"
+ },
"key": {
"title": "Key",
"type": "string"
@@ -2750,6 +2893,11 @@
"GetXComCount": {
"description": "Get the number of (mapped) XCom values available.",
"properties": {
+ "previous_iteration": {
+ "default": false,
+ "title": "Previous Iteration",
+ "type": "boolean"
+ },
"key": {
"title": "Key",
"type": "string"
@@ -2784,6 +2932,11 @@
},
"GetXComSequenceItem": {
"properties": {
+ "previous_iteration": {
+ "default": false,
+ "title": "Previous Iteration",
+ "type": "boolean"
+ },
"key": {
"title": "Key",
"type": "string"
@@ -2823,6 +2976,11 @@
},
"GetXComSequenceSlice": {
"properties": {
+ "previous_iteration": {
+ "default": false,
+ "title": "Previous Iteration",
+ "type": "boolean"
+ },
"key": {
"title": "Key",
"type": "string"
@@ -3045,7 +3203,17 @@
"title": "InactiveAssetsResult",
"type": "object"
},
- "JsonValue": {},
+ "JsonValue": {
+ "title": "JsonValue",
+ "type": [
+ "object",
+ "array",
+ "string",
+ "number",
+ "boolean",
+ "null"
+ ]
+ },
"LazyDeserializedDAG": {
"description": "Lazily build information from the serialized DAG
structure.\n\nAn object that will present \"enough\" of the DAG like interface
to update DAG db models etc, without having\nto deserialize the full DAG and
Task hierarchy.",
"properties": {
@@ -3074,6 +3242,33 @@
"title": "LazyDeserializedDAG",
"type": "object"
},
+ "LoopDecisionPayload": {
+ "additionalProperties": false,
+ "description": "A loop gate's evaluation of its ``until`` callable.",
+ "properties": {
+ "stop": {
+ "title": "Stop",
+ "type": "boolean"
+ },
+ "reason": {
+ "anyOf": [
+ {
+ "type": "string"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "default": null,
+ "title": "Reason"
+ }
+ },
+ "required": [
+ "stop"
+ ],
+ "title": "LoopDecisionPayload",
+ "type": "object"
+ },
"MaskSecret": {
"description": "Add a new value to be redacted in task logs.",
"properties": {
@@ -3294,6 +3489,31 @@
"default": -1,
"title": "Map Index"
},
+ "region_id": {
+ "anyOf": [
+ {
+ "format": "uuid",
+ "type": "string"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "default": null,
+ "title": "Region Id"
+ },
+ "region_index": {
+ "anyOf": [
+ {
+ "type": "integer"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "default": null,
+ "title": "Region Index"
+ },
"duration": {
"anyOf": [
{
@@ -3388,17 +3608,10 @@
"description": "Update a task instance state to
reschedule/up_for_reschedule.",
"properties": {
"state": {
- "anyOf": [
- {
- "const": "up_for_reschedule",
- "type": "string"
- },
- {
- "type": "null"
- }
- ],
+ "const": "up_for_reschedule",
"default": "up_for_reschedule",
- "title": "State"
+ "title": "State",
+ "type": "string"
},
"reschedule_date": {
"format": "date-time",
@@ -3441,17 +3654,10 @@
"description": "Update a task instance state to up_for_retry.",
"properties": {
"state": {
- "anyOf": [
- {
- "const": "up_for_retry",
- "type": "string"
- },
- {
- "type": "null"
- }
- ],
+ "const": "up_for_retry",
"default": "up_for_retry",
- "title": "State"
+ "title": "State",
+ "type": "string"
},
"end_date": {
"format": "date-time",
@@ -3585,6 +3791,27 @@
"title": "SetAssetStateStoreByUri",
"type": "object"
},
+ "SetExecutionTimeout": {
+ "description": "Tell the supervisor the task's ``execution_timeout`` so
it can enforce it from outside the task process.",
+ "properties": {
+ "timeout_seconds": {
+ "exclusiveMinimum": 0,
+ "title": "Timeout Seconds",
+ "type": "number"
+ },
+ "type": {
+ "const": "SetExecutionTimeout",
+ "default": "SetExecutionTimeout",
+ "title": "Type",
+ "type": "string"
+ }
+ },
+ "required": [
+ "timeout_seconds"
+ ],
+ "title": "SetExecutionTimeout",
+ "type": "object"
+ },
"SetRenderedFields": {
"description": "Payload for setting RTIF for a task instance.",
"properties": {
@@ -3825,17 +4052,10 @@
"description": "Update a task's state to success. Includes task_outlets
and outlet_events for registering asset events.",
"properties": {
"state": {
- "anyOf": [
- {
- "const": "success",
- "type": "string"
- },
- {
- "type": "null"
- }
- ],
+ "const": "success",
"default": "success",
- "title": "State"
+ "title": "State",
+ "type": "string"
},
"end_date": {
"format": "date-time",
@@ -3885,6 +4105,17 @@
"default": null,
"title": "Rendered Map Index"
},
+ "loop_decision": {
+ "anyOf": [
+ {
+ "$ref": "#/$defs/LoopDecisionPayload"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "default": null
+ },
"type": {
"const": "SucceedTask",
"default": "SucceedTask",
@@ -4119,6 +4350,29 @@
],
"default": null,
"title": "Rendered Map Index"
+ },
+ "retry_reason": {
+ "anyOf": [
+ {
+ "type": "string"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "default": null,
+ "title": "Retry Reason"
+ },
+ "loop_decision": {
+ "anyOf": [
+ {
+ "$ref": "#/$defs/LoopDecisionPayload"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "default": null
}
},
"required": [
@@ -4132,7 +4386,14 @@
"description": "Response to GetTaskStateStore; wraps the generated API
response for supervisor to worker comms.",
"properties": {
"value": {
- "$ref": "#/$defs/JsonValue"
+ "anyOf": [
+ {
+ "$ref": "#/$defs/JsonValue"
+ },
+ {
+ "type": "null"
+ }
+ ]
},
"type": {
"const": "TaskStateStoreResult",
@@ -4267,6 +4528,38 @@
"title": "TriggerDagRun",
"type": "object"
},
+ "UpdateDagRunNote": {
+ "properties": {
+ "ti_id": {
+ "format": "uuid",
+ "title": "Ti Id",
+ "type": "string"
+ },
+ "note": {
+ "anyOf": [
+ {
+ "type": "string"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "title": "Note"
+ },
+ "type": {
+ "const": "UpdateDagRunNote",
+ "default": "UpdateDagRunNote",
+ "title": "Type",
+ "type": "string"
+ }
+ },
+ "required": [
+ "ti_id",
+ "note"
+ ],
+ "title": "UpdateDagRunNote",
+ "type": "object"
+ },
"UpdateHITLDetail": {
"description": "Update the response content part of an existing
Human-in-the-loop response.",
"properties": {
@@ -4357,6 +4650,33 @@
"title": "VariableKeysResult",
"type": "object"
},
+ "VariableResponse": {
+ "additionalProperties": false,
+ "description": "Variable schema for responses with fields that are
needed for Runtime.",
+ "properties": {
+ "key": {
+ "title": "Key",
+ "type": "string"
+ },
+ "value": {
+ "anyOf": [
+ {
+ "type": "string"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "title": "Value"
+ }
+ },
+ "required": [
+ "key",
+ "value"
+ ],
+ "title": "VariableResponse",
+ "type": "object"
+ },
"VariableResult": {
"additionalProperties": false,
"properties": {
@@ -4373,7 +4693,6 @@
"type": "null"
}
],
- "default": null,
"title": "Value"
},
"type": {
@@ -4384,7 +4703,8 @@
}
},
"required": [
- "key"
+ "key",
+ "value"
],
"title": "VariableResult",
"type": "object"
@@ -4416,7 +4736,14 @@
"type": "string"
},
"value": {
- "$ref": "#/$defs/JsonValue"
+ "anyOf": [
+ {
+ "$ref": "#/$defs/JsonValue"
+ },
+ {
+ "type": "null"
+ }
+ ]
},
"type": {
"const": "XComResult",
@@ -4472,97 +4799,6 @@
"title": "XComSequenceSliceResult",
"type": "object"
},
- "ConnectionResponse": {
- "description": "Connection schema for responses with fields that are
needed for Runtime.",
- "properties": {
- "conn_id": {
- "title": "Conn Id",
- "type": "string"
- },
- "conn_type": {
- "title": "Conn Type",
- "type": "string"
- },
- "host": {
- "anyOf": [
- {
- "type": "string"
- },
- {
- "type": "null"
- }
- ],
- "title": "Host"
- },
- "schema": {
- "anyOf": [
- {
- "type": "string"
- },
- {
- "type": "null"
- }
- ],
- "title": "Schema"
- },
- "login": {
- "anyOf": [
- {
- "type": "string"
- },
- {
- "type": "null"
- }
- ],
- "title": "Login"
- },
- "password": {
- "anyOf": [
- {
- "type": "string"
- },
- {
- "type": "null"
- }
- ],
- "title": "Password"
- },
- "port": {
- "anyOf": [
- {
- "type": "integer"
- },
- {
- "type": "null"
- }
- ],
- "title": "Port"
- },
- "extra": {
- "anyOf": [
- {
- "type": "string"
- },
- {
- "type": "null"
- }
- ],
- "title": "Extra"
- }
- },
- "required": [
- "conn_id",
- "conn_type",
- "host",
- "schema",
- "login",
- "password",
- "port",
- "extra"
- ],
- "title": "ConnectionResponse",
- "type": "object"
- },
"ArgValueSchema": {
"additionalProperties": {
"$ref": "#/$defs/JsonValue"
@@ -4573,11 +4809,6 @@
"LiteralArgBinding": {
"description": "One positional stub-task argument carrying an inline
literal from the Dag file.",
"properties": {
- "kind": {
- "const": "literal",
- "title": "Kind",
- "type": "string"
- },
"name": {
"title": "Name",
"type": "string"
@@ -4593,6 +4824,11 @@
],
"default": null
},
+ "kind": {
+ "const": "literal",
+ "title": "Kind",
+ "type": "string"
+ },
"value": {
"anyOf": [
{
@@ -4611,8 +4847,8 @@
}
},
"required": [
- "kind",
- "name"
+ "name",
+ "kind"
],
"title": "LiteralArgBinding",
"type": "object"
@@ -4638,11 +4874,6 @@
"XComArgBinding": {
"description": "One positional stub-task argument pulled from an
upstream task's XCom.",
"properties": {
- "kind": {
- "const": "xcom",
- "title": "Kind",
- "type": "string"
- },
"name": {
"title": "Name",
"type": "string"
@@ -4658,31 +4889,19 @@
],
"default": null
},
+ "kind": {
+ "const": "xcom",
+ "title": "Kind",
+ "type": "string"
+ },
"task_id": {
"title": "Task Id",
"type": "string"
- },
- "map_index": {
- "default": -1,
- "title": "Map Index",
- "type": "integer"
- },
- "element_index": {
- "anyOf": [
- {
- "type": "integer"
- },
- {
- "type": "null"
- }
- ],
- "default": null,
- "title": "Element Index"
}
},
"required": [
- "kind",
"name",
+ "kind",
"task_id"
],
"title": "XComArgBinding",
@@ -4784,6 +5003,34 @@
"title": "AssetEventDagRunReference",
"type": "object"
},
+ "AssetReferenceAssetEventDagRun": {
+ "additionalProperties": false,
+ "description": "Schema for AssetModel used in
AssetEventDagRunReference.",
+ "properties": {
+ "name": {
+ "title": "Name",
+ "type": "string"
+ },
+ "uri": {
+ "title": "Uri",
+ "type": "string"
+ },
+ "extra": {
+ "additionalProperties": {
+ "$ref": "#/$defs/JsonValue"
+ },
+ "title": "Extra",
+ "type": "object"
+ }
+ },
+ "required": [
+ "name",
+ "uri",
+ "extra"
+ ],
+ "title": "AssetReferenceAssetEventDagRun",
+ "type": "object"
+ },
"DagRun": {
"additionalProperties": false,
"description": "Schema for DagRun model with minimal required fields
needed for Runtime.",
@@ -4970,17 +5217,102 @@
"title": "DagRun",
"type": "object"
},
+ "LoopContext": {
+ "description": "Pinned loop definition and enclosing iteration for a
task execution.",
+ "properties": {
+ "node_id": {
+ "title": "Node Id",
+ "type": "string"
+ },
+ "index": {
+ "minimum": 1,
+ "title": "Index",
+ "type": "integer"
+ },
+ "max_iterations": {
+ "exclusiveMinimum": 0,
+ "title": "Max Iterations",
+ "type": "integer"
+ },
+ "terminal_task_id": {
+ "title": "Terminal Task Id",
+ "type": "string"
+ },
+ "terminal_is_mapped": {
+ "title": "Terminal Is Mapped",
+ "type": "boolean"
+ },
+ "region_id": {
+ "format": "uuid",
+ "title": "Region Id",
+ "type": "string"
+ },
+ "trajectory": {
+ "minimum": 1,
+ "title": "Trajectory",
+ "type": "integer"
+ },
+ "forked_from_region_id": {
+ "format": "uuid",
+ "title": "Forked From Region Id",
+ "type": "string"
+ },
+ "resumes_from_index": {
+ "title": "Resumes From Index",
+ "type": "integer"
+ }
+ },
+ "required": [
+ "node_id",
+ "index",
+ "max_iterations",
+ "terminal_task_id",
+ "terminal_is_mapped",
+ "region_id",
+ "trajectory"
+ ],
+ "title": "LoopContext",
+ "type": "object"
+ },
"TIRunContext": {
"description": "Response schema for TaskInstance run context.",
"properties": {
"dag_run": {
"$ref": "#/$defs/DagRun"
},
+ "loop": {
+ "anyOf": [
+ {
+ "$ref": "#/$defs/LoopContext"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "default": null
+ },
+ "expanded_ti_count": {
+ "title": "Expanded Ti Count",
+ "type": "integer"
+ },
"task_reschedule_count": {
"default": 0,
"title": "Task Reschedule Count",
"type": "integer"
},
+ "first_task_reschedule_start_date": {
+ "anyOf": [
+ {
+ "format": "date-time",
+ "type": "string"
+ },
+ {
+ "type": "null"
+ }
+ ],
+ "default": null,
+ "title": "First Task Reschedule Start Date"
+ },
"max_tries": {
"title": "Max Tries",
"type": "integer"
@@ -5066,6 +5398,11 @@
],
"default": null,
"title": "Arg Bindings"
+ },
+ "multi_team": {
+ "default": false,
+ "title": "Multi Team",
+ "type": "boolean"
}
},
"required": [
@@ -5109,6 +5446,15 @@
"title": "Map Index",
"type": "integer"
},
+ "region_id": {
+ "format": "uuid",
+ "title": "Region Id",
+ "type": "string"
+ },
+ "region_index": {
+ "title": "Region Index",
+ "type": "integer"
+ },
"hostname": {
"anyOf": [
{
@@ -5150,33 +5496,6 @@
],
"title": "TaskInstance",
"type": "object"
- },
- "VariableResponse": {
- "additionalProperties": false,
- "description": "Variable schema for responses with fields that are
needed for Runtime.",
- "properties": {
- "key": {
- "title": "Key",
- "type": "string"
- },
- "value": {
- "anyOf": [
- {
- "type": "string"
- },
- {
- "type": "null"
- }
- ],
- "title": "Value"
- }
- },
- "required": [
- "key",
- "value"
- ],
- "title": "VariableResponse",
- "type": "object"
}
}
}
diff --git a/kubernetes-tests/lang_sdk/java_example/gradle.properties
b/kubernetes-tests/lang_sdk/java_example/gradle.properties
index d823c0c35d9..e01e7c347a7 100644
--- a/kubernetes-tests/lang_sdk/java_example/gradle.properties
+++ b/kubernetes-tests/lang_sdk/java_example/gradle.properties
@@ -16,4 +16,4 @@
# specific language governing permissions and limitations
# under the License.
#
-projectVersion=1.0.0-SNAPSHOT
+projectVersion=1.0.0
