From 3a579f23469c66e95271d4c79ebd27db2fdd2182 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=80=97=E5=AD=90?= <i@haozi.net>
Date: Mon, 4 Nov 2024 17:59:13 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E8=BF=90=E8=A1=8C=E7=AD=89=E5=BE=85?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E5=89=8D=E6=A0=87=E8=AE=B0=E5=85=88=E5=89=8D?=
 =?UTF-8?q?=E8=BF=90=E8=A1=8C=E4=B8=AD=E7=9A=84=E4=BB=BB=E5=8A=A1=E4=B8=BA?=
 =?UTF-8?q?=E5=A4=B1=E8=B4=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/data/task.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/internal/data/task.go b/internal/data/task.go
index e6fe70ab..20b24140 100644
--- a/internal/data/task.go
+++ b/internal/data/task.go
@@ -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))