fix: handle error from GetExecSqlsByTaskIdAndStatus in action execution

iwanghc · iwanghc · commit f7178efe3703 · 2025-10-20T14:32:43.000+08:00
diff --git a/sqle/server/sqled.go b/sqle/server/sqled.go
@@ -400,9 +400,9 @@ func (a *action) execute() (err error) {
 		}
 		// update task status by sql
 		// 验证task下所有的sql是否全部成功（工单中允许重新上线部分sql，所以需要验证全部sql是否成功）
-		failedSqls, err := st.GetExecSqlsByTaskIdAndStatus(task.ID, []string{model.SQLExecuteStatusFailed, model.SQLExecuteStatusTerminateSucc})
-		if err != nil {
-			return err
+		failedSqls, queryErr := st.GetExecSqlsByTaskIdAndStatus(task.ID, []string{model.SQLExecuteStatusFailed, model.SQLExecuteStatusTerminateSucc})
+		if queryErr != nil {
+			return queryErr
 		}
 		if len(failedSqls) > 0 {
 			taskStatus = model.TaskStatusExecuteFailed

Original file line number	Diff line number	Diff line change
`@@ -400,9 +400,9 @@ func (a *action) execute() (err error) {`
`400`	`400`	`}`
`401`	`401`	`// update task status by sql`
`402`	`402`	`// 验证task下所有的sql是否全部成功（工单中允许重新上线部分sql，所以需要验证全部sql是否成功）`
`403`		`- failedSqls, err := st.GetExecSqlsByTaskIdAndStatus(task.ID, []string{model.SQLExecuteStatusFailed, model.SQLExecuteStatusTerminateSucc})`
`404`		`- if err != nil {`
`405`		`- return err`
	`403`	`+ failedSqls, queryErr := st.GetExecSqlsByTaskIdAndStatus(task.ID, []string{model.SQLExecuteStatusFailed, model.SQLExecuteStatusTerminateSucc})`
	`404`	`+ if queryErr != nil {`
	`405`	`+ return queryErr`
`406`	`406`	`}`
`407`	`407`	`if len(failedSqls) > 0 {`
`408`	`408`	`taskStatus = model.TaskStatusExecuteFailed`