From 1d555248a10f05200fbe07f462f3702bf3181dea Mon Sep 17 00:00:00 2001 From: xiaoxia Date: Fri, 14 Aug 2026 17:22:43 +0800 Subject: [PATCH] fix: resolve resource leak and thumbnail size issues --- apps/worker/worker_app/tasks/ingest.py | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/apps/worker/worker_app/tasks/ingest.py b/apps/worker/worker_app/tasks/ingest.py index cbac4918f..10b4beefb 100755 --- a/apps/worker/worker_app/tasks/ingest.py +++ b/apps/worker/worker_app/tasks/ingest.py @@ -210,13 +210,15 @@ def ingest_asset(job_id: str) -> dict: from video_processing.oss_helpers import upload_to_oss from video_processing.thumbnail_generator import extract_first_frame - frame_path = extract_first_frame(str(local_file)) + frame_path = extract_first_frame(str(local_file), width=640) thumb_storage_key = f"assets/{job.project_id}/thumbnails/{job_id}.jpg" - thumbnail_url = upload_to_oss(frame_path, thumb_storage_key) try: - Path(frame_path).unlink(missing_ok=True) - except Exception: - pass + thumbnail_url = upload_to_oss(frame_path, thumb_storage_key) + finally: + try: + Path(frame_path).unlink(missing_ok=True) + except Exception: + pass if thumbnail_url: logger.info( "素材缩略图生成成功: job_id=%s url=%s", @@ -338,3 +340,4 @@ def ingest_asset(job_id: str) -> dict: } finally: db.close() +