From 58dd72fd1bcb1aa3382b3ce2c2c24e0c55bd7d53 Mon Sep 17 00:00:00 2001
From: Joftal <42807405+Joftal@users.noreply.github.com>
Date: Tue, 11 Aug 2026 15:40:36 +0800
Subject: [PATCH] =?UTF-8?q?fix(pipeline):=20=E4=BF=AE=E5=A4=8D=20delete=5F?=
 =?UTF-8?q?after=20=E6=A8=A1=E5=BC=8F=E5=AD=A4=E7=AB=8B=20.ass=20=E6=9C=AA?=
 =?UTF-8?q?=E6=B8=85=E7=90=86=E5=8F=8A=E5=8F=96=E6=B6=88=E5=90=8E=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E7=8A=B6=E6=80=81=E4=B8=8D=E4=B8=80=E8=87=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- deleteMarkedFiles: deleteAfter 模式下也运行 cleanupOrphanedAssFiles
  修复视频上传删除后 .ass 文件残留在磁盘的问题
- cleanupOrphanedAssFiles: 改用视频基名匹配替代 allAssFiles 过滤
  解决 .ass 从未传入 Pipeline 导致过滤条件失效的问题
- Execute: 全部阶段成功但 ctx 取消时返回 ctx.Err() 而非 nil
  使任务标记为 Cancelled 而非 Completed，与磁盘状态（文件保留）一致
---
 src/pipeline/executor.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/pipeline/executor.go b/src/pipeline/executor.go
index 10edf4c..0949aec 100644
--- a/src/pipeline/executor.go
+++ b/src/pipeline/executor.go
@@ -56,7 +56,7 @@ func (e *Executor) Execute(
 	initialFiles []FileInfo,
 	startStage int,
 	onProgress func(stageIndex int, stageName string, status StageStatus),
-	onStageComplete func(stageIndex int, outputFiles []FileInfo),
+	onStageComplete func(stageIndex int, result StageResult),
 ) ([]StageResult, error) {
 	if config == nil || len(config.Stages) == 0 {
 		e.logger.Debug("pipeline config is empty, skipping")
@@ -149,7 +149,7 @@ func (e *Executor) Execute(
 
 		// 通知外部持久化阶段完成状态（用于崩溃恢复）
 		if onStageComplete != nil {
-			onStageComplete(stageIndex, output)
+			onStageComplete(stageIndex, result)
 		}
 
 		// 更新文件列表给下一阶段
@@ -163,13 +163,13 @@ func (e *Executor) Execute(
 	}
 
 	// 全部成功：执行延迟删除，并让最终结果反映磁盘上的文件
-	// 如果上下文已取消，跳过删除以保留所有文件
+	// 如果上下文已取消，跳过删除以保留所有文件，返回取消错误让任务标记为 Cancelled
 	if ctx.Ctx.Err() != nil {
 		e.logger.Warn("pipeline cancelled after completion, skipping file cleanup")
 		if len(results) > 0 {
 			results[len(results)-1].OutputFiles = files
 		}
-		return results, nil
+		return results, ctx.Ctx.Err()
 	}
 	keptFiles := e.deleteMarkedFiles(files)
 	if len(results) > 0 {