This is an automated email from the ASF dual-hosted git repository.
pierrejeambrun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new b8475094703 Fix go-sdk generated drift (#74028)
b8475094703 is described below
commit b84750947032a8dfe7011f2e74fd32d42960767d
Author: Wei Lee <[email protected]>
AuthorDate: Thu Oct 1 23:05:06 2026 +0900
Fix go-sdk generated drift (#74028)
---
.../pkg/execution/genmodels/discriminators.gen.go | 4 ++
go-sdk/pkg/execution/genmodels/models.gen.go | 54 ++++++++++++++++------
2 files changed, 45 insertions(+), 13 deletions(-)
diff --git a/go-sdk/pkg/execution/genmodels/discriminators.gen.go
b/go-sdk/pkg/execution/genmodels/discriminators.gen.go
index 027a512a728..09da3118f55 100644
--- a/go-sdk/pkg/execution/genmodels/discriminators.gen.go
+++ b/go-sdk/pkg/execution/genmodels/discriminators.gen.go
@@ -105,6 +105,7 @@ const (
TypeTaskStateStoreResult = "TaskStateStoreResult"
TypeTaskStatesResult = "TaskStatesResult"
TypeTriggerDagRun = "TriggerDagRun"
+ TypeUpdateDagRunNote = "UpdateDagRunNote"
TypeUpdateHITLDetail = "UpdateHITLDetail"
TypeValidateInletsAndOutlets = "ValidateInletsAndOutlets"
TypeVariableKeysResult = "VariableKeysResult"
@@ -364,6 +365,9 @@ func EnsureType(m any) any {
case TriggerDagRun:
b.Type = TypeTriggerDagRun
return b
+ case UpdateDagRunNote:
+ b.Type = TypeUpdateDagRunNote
+ return b
case UpdateHITLDetail:
b.Type = TypeUpdateHITLDetail
return b
diff --git a/go-sdk/pkg/execution/genmodels/models.gen.go
b/go-sdk/pkg/execution/genmodels/models.gen.go
index 22741803d83..dee470082f1 100644
--- a/go-sdk/pkg/execution/genmodels/models.gen.go
+++ b/go-sdk/pkg/execution/genmodels/models.gen.go
@@ -407,12 +407,18 @@ type DagFileParseRequest struct {
// serialized DAGs,
// import errors and warnings to send back to the scheduler to store in the DB.
type DagFileParsingResult struct {
+ // DagSourceCodes corresponds to the JSON schema field
"dag_source_codes".
+ DagSourceCodes DagSourceCodes `msgpack:"dag_source_codes,omitempty"`
+
// Fileloc corresponds to the JSON schema field "fileloc".
Fileloc string `msgpack:"fileloc"`
// ImportErrors corresponds to the JSON schema field "import_errors".
ImportErrors *ImportErrors `msgpack:"import_errors,omitempty"`
+ // ParsedDefinitions corresponds to the JSON schema field
"parsed_definitions".
+ ParsedDefinitions []string `msgpack:"parsed_definitions,omitempty"`
+
// SerializedDags corresponds to the JSON schema field
"serialized_dags".
SerializedDags []LazyDeserializedDAG `msgpack:"serialized_dags"`
@@ -634,6 +640,17 @@ const DagRunTypeManual DagRunType = "manual"
const DagRunTypeOperatorTriggered DagRunType = "operator_triggered"
const DagRunTypeScheduled DagRunType = "scheduled"
+// Raw source code and its language identifier for a DAG definition.
+type DagSourceCode struct {
+ // Language corresponds to the JSON schema field "language".
+ Language string `msgpack:"language"`
+
+ // SourceCode corresponds to the JSON schema field "source_code".
+ SourceCode string `msgpack:"source_code"`
+}
+
+type DagSourceCodes map[string]DagSourceCode
+
type Data map[string]interface{}
type Defaults []string
@@ -1839,6 +1856,17 @@ type TriggerDagRun struct {
type TriggerKwargs map[string]interface{}
+type UpdateDagRunNote struct {
+ // Note corresponds to the JSON schema field "note".
+ Note interface{} `msgpack:"note"`
+
+ // TIID corresponds to the JSON schema field "ti_id".
+ TIID string `msgpack:"ti_id"`
+
+ // Type corresponds to the JSON schema field "type".
+ Type string `msgpack:"type,omitempty"`
+}
+
// Update the response content part of an existing Human-in-the-loop response.
type UpdateHITLDetail struct {
// ChosenOptions corresponds to the JSON schema field "chosen_options".
@@ -1854,6 +1882,19 @@ type UpdateHITLDetail struct {
Type string `msgpack:"type,omitempty"`
}
+// Variable schema for responses with fields that are needed for Runtime.
+type VariableResponse struct {
+ // Key corresponds to the JSON schema field "key".
+ Key string `msgpack:"key"`
+
+ // Value corresponds to the JSON schema field "value".
+ Value interface{} `msgpack:"value"`
+}
+
+type Warnings []interface{}
+
+type VersionData map[string]interface{}
+
type ValidateInletsAndOutlets struct {
// TIID corresponds to the JSON schema field "ti_id".
TIID string `msgpack:"ti_id"`
@@ -1873,15 +1914,6 @@ type VariableKeysResult struct {
Type string `msgpack:"type,omitempty"`
}
-// Variable schema for responses with fields that are needed for Runtime.
-type VariableResponse struct {
- // Key corresponds to the JSON schema field "key".
- Key string `msgpack:"key"`
-
- // Value corresponds to the JSON schema field "value".
- Value interface{} `msgpack:"value"`
-}
-
type VariableResult struct {
// Key corresponds to the JSON schema field "key".
Key string `msgpack:"key"`
@@ -1893,10 +1925,6 @@ type VariableResult struct {
Value interface{} `msgpack:"value"`
}
-type VersionData map[string]interface{}
-
-type Warnings []interface{}
-
// One positional stub-task argument pulled from an upstream task's XCom.
type XComArgBinding struct {
// Kind corresponds to the JSON schema field "kind".
