acepanel/panel
2
0
Fork 0
mirror of https://github.com/acepanel/panel.git synced 2026-02-04 12:40:25 +08:00
Code Issues Packages Releases Activity

feat: 运行等待任务前标记先前运行中的任务为失败

Browse Source
This commit is contained in:
耗子
2024-11-04 17:59:13 +08:00
parent e85e8dffb3
commit 3a579f2346
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
internal/data/task.go
View File

@@ -71,6 +71,11 @@ func (r *taskRepo) DispatchWaiting() {
return
}
if err := app.Orm.Model(&biz.Task{}).Where("status = ?", biz.TaskStatusRunning).Update("status", biz.TaskStatusFailed).Error; err != nil {
app.Logger.Warn("failed to mark running tasks as failed", slog.Any("err", err))
return
}
var tasks []biz.Task
if err := app.Orm.Where("status = ?", biz.TaskStatusWaiting).Find(&tasks).Error; err != nil {
app.Logger.Warn("failed to get pending tasks", slog.Any("err", err))