From b469817ef1469e2e8e66cf4c17da63decfa09c92 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E6=96=8C?= <259278618@qq.com>
Date: Wed, 8 Jul 2026 15:04:52 +0800
Subject: [PATCH] 1

---
 shortdrama/service/drama_service.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/shortdrama/service/drama_service.go b/shortdrama/service/drama_service.go
index 9e57c40..7773aec 100644
--- a/shortdrama/service/drama_service.go
+++ b/shortdrama/service/drama_service.go
@@ -871,7 +871,9 @@ func (s *dramaService) pollPendingVideos(ctx context.Context) {
 						gcache.Remove(ctx, cacheKeyConfig)
 						epUpdates[task.EpisodeId] = true
 					} else {
-						g.Log().Warningf(ctx, "轮询器: 任务 %d 第%d段视频任务失败: %v（保留 task_id，不会重新提交消耗额度）", task.Id, task.SegmentIdx+1, err)
+						g.Log().Warningf(ctx, "轮询器: 任务 %d 第%d段视频任务失败: %v", task.Id, task.SegmentIdx+1, err)
+						_ = dao.GenerationTask.UpdateFailed(ctx, task.Id, err.Error())
+						epUpdates[task.EpisodeId] = true
 					}
 				} else if strings.Contains(err.Error(), "RUNNING") {
 					g.Log().Debugf(ctx, "轮询器: 任务 %d 第%d段视频正在生成中，继续等待...", task.Id, task.SegmentIdx+1)