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