This is an automated email from the ASF dual-hosted git repository. vatsrahul1001 pushed a commit to branch v3-4-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit b9bdb4c183559dd0ee8e87ce1da7f09675983c6d 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
