fix: 将try块上移到render_temp_dir赋值之后，确保异常时也清理临时目录

2026-08-24 20:59:13 +08:00
parent 4295f20fd6
commit 6b67bb948b
1 changed files with 10 additions and 10 deletions
@@ -699,16 +699,16 @@ def generate_video(self, task_id: str) -> dict:
                        task_info=task_info,
                    )
                )
-
-                if gen_task:
-                    gen_task.append_log("渲染", f"渲染完成, 时长={render_duration:.1f}s")
-                    _flush_logs(task_id, gen_task)
-
-                _update_task_progress(task_id, 80, "渲染完成")
-
-                # ── 4. 上传 OSS + 查重记录（临时目录在 finally 中清理）───────
-                _update_task_progress(task_id, 85, "开始上传")
+                # 从这里开始，render_temp_dir 已赋值，必须确保异常时也能清理
                try:
+                    if gen_task:
+                        gen_task.append_log("渲染", f"渲染完成, 时长={render_duration:.1f}s")
+                        _flush_logs(task_id, gen_task)
+
+                    _update_task_progress(task_id, 80, "渲染完成")
+
+                    # ── 4. 上传 OSS + 查重记录 ───────────────────────────────
+                    _update_task_progress(task_id, 85, "开始上传")
                    file_url, duration, file_size, video_count = _upload_and_record(
                        task_id=task_id,
                        output_path=output_path,
@@ -730,7 +730,7 @@ def generate_video(self, task_id: str) -> dict:

                    _update_task_progress(task_id, 95, "上传完成")
                finally:
-                    # 清理渲染临时目录（无论上传成功与否都清理）
+                    # 清理渲染临时目录（无论后续步骤成功与否都清理）
                    if render_temp_dir:
                        import shutil