1

2026-07-08 15:04:52 +08:00
parent b92803185e
commit b469817ef1
1 changed files with 3 additions and 1 deletions
@@ -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)