From 4479544c18040dc08861d74492f5ec7208bd1626 Mon Sep 17 00:00:00 2001 From: imeepos Date: Tue, 23 Sep 2025 10:53:58 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8DHTTP=E5=8D=8F=E8=AE=AE?= =?UTF-8?q?=E8=A7=86=E9=A2=91=E4=B8=8B=E8=BD=BD=E5=AE=8C=E6=88=90=E5=90=8E?= =?UTF-8?q?=E7=8A=B6=E6=80=81=E6=9C=AA=E6=9B=B4=E6=96=B0=E7=9A=84=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 在HTTP协议处理中添加volume_cache_path设置 - 确保下载成功后状态正确更新为ready - 添加process_span.set_status("success")标记成功状态 修复问题: - 文件下载完成但status仍为downloading - local_exists为true但local_available为false - 状态更新逻辑因缺少volume_cache_path而失效 --- src/cluster/video_apps/cache_submit.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/cluster/video_apps/cache_submit.py b/src/cluster/video_apps/cache_submit.py index 5843cb9..05eada2 100644 --- a/src/cluster/video_apps/cache_submit.py +++ b/src/cluster/video_apps/cache_submit.py @@ -193,6 +193,8 @@ with downloader_image.imports(): cache_filepath = f"{config.S3_mount_dir}/{media.cache_filepath}" os.makedirs(os.path.dirname(cache_filepath), exist_ok=True) download_large_file(url=media.__str__(), output_path=cache_filepath) + volume_cache_path = cache_filepath # 设置volume_cache_path用于状态更新 + process_span.set_status("success") except Exception as e: logger.exception(e) media.status = MediaCacheStatus.failed