From 9afb30c5a09177dd94229b622cc2f8d3e9fcf2aa Mon Sep 17 00:00:00 2001
From: Vincent Hsiao <124506982+fat-catTW@users.noreply.github.com>
Date: Mon, 2 Nov 2026 14:30:33 +0800
Subject: [PATCH] Go SDK: Keep nested Conf validation test compatible across Go
 versions (#75971)

---
 go-sdk/airflow/trigger_dag_run_test.go | 22 ++++++++++++++--------
 1 file changed, 14 insertions(+), 8 deletions(-)

diff --git a/go-sdk/airflow/trigger_dag_run_test.go b/go-sdk/airflow/trigger_dag_run_test.go
index fdfe813c645..adee138f790 100644
--- a/go-sdk/airflow/trigger_dag_run_test.go
+++ b/go-sdk/airflow/trigger_dag_run_test.go
@@ -102,9 +102,10 @@ func buildNestedConf(depth int) map[string]any {
 
 func TestTriggerDagRunRejectsAnInvalidSpec(t *testing.T) {
 	tests := []struct {
-		name    string
-		trigger TriggerDagRunTask
-		want    string
+		name              string
+		trigger           TriggerDagRunTask
+		want              string
+		wantPanicContains string
 	}{
 		{
 			name:    "no DagID",
@@ -206,16 +207,21 @@ func TestTriggerDagRunRejectsAnInvalidSpec(t *testing.T) {
 			trigger: TriggerDagRun(
 				TriggerDagRunSpec{DagID: "downstream_etl", Conf: buildNestedConf(10001)},
 			),
-			want: "airflow.TriggerDagRunSpec.Conf: invalid character '{' exceeded max depth",
+			wantPanicContains: "exceeded max depth",
 		},
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
 			dag := Dag("etl")
-			assert.PanicsWithValue(t,
-				`airflow.DagRef.Task: task "trigger_downstream" of Dag "etl": `+tt.want,
-				func() { dag.Task(tt.trigger, TaskSpec{TaskID: "trigger_downstream"}) },
-			)
+			panicFunc := func() { dag.Task(tt.trigger, TaskSpec{TaskID: "trigger_downstream"}) }
+			if tt.wantPanicContains != "" {
+				assert.Contains(t, panicMessage(t, panicFunc), tt.wantPanicContains)
+			} else {
+				assert.PanicsWithValue(t,
+					`airflow.DagRef.Task: task "trigger_downstream" of Dag "etl": `+tt.want,
+					panicFunc,
+				)
+			}
 			assert.NotPanics(t,
 				func() { dag.Task(extract, TaskSpec{TaskID: "trigger_downstream"}) },
 				"a rejected task does not take its task_id",