fix(framework): fix errors when updating is_failed in PG (#8238)

apache · Dec 12, 2024 · ba7edd6 · ba7edd6
1 parent 72c6433
commit ba7edd6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/backend/core/runner/run_task.go b/backend/core/runner/run_task.go
@@ -334,7 +334,7 @@ func RunPluginSubTasks(
 				logger.Error(err, "")
 				where := dal.Where("task_id = ? and name = ?", task.ID, subtaskCtx.GetName())
 				if err := basicRes.GetDal().UpdateColumns(subtask, []dal.DalSet{
-					{ColumnName: "is_failed", Value: 1},
+					{ColumnName: "is_failed", Value: true},
 					{ColumnName: "message", Value: err.Error()},
 				}, where); err != nil {
 					basicRes.GetLogger().Error(err, "error writing subtask %v status to DB", subtaskCtx.GetName())