check msgOption is Valid before convert it to msg

matrixorigin · Sep 2, 2024 · 28e1a2f · 28e1a2f
1 parent bb45d0d
commit 28e1a2f
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/pkg/taskservice/mysql_task_storage.go b/pkg/taskservice/mysql_task_storage.go
@@ -386,11 +386,13 @@ func (m *mysqlTaskStorage) QueryAsyncTask(ctx context.Context, condition ...Cond
 			}
 			t.ExecuteResult.Code = task.ResultCode(code.(int64))
 
-			msg, err := msgOption.Value()
-			if err != nil {
-				return nil, err
+			if msgOption.Valid {
+				msg, err := msgOption.Value()
+				if err != nil {
+					return nil, err
+				}
+				t.ExecuteResult.Error = msg.(string)
 			}
-			t.ExecuteResult.Error = msg.(string)
 		}
 
 		tasks = append(tasks, t)