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

apache · Dec 12, 2024 · c048951 · c048951
1 parent 4305b78
commit c048951
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
@@ -335,7 +335,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())