fix: 修复上传路径

tianxiu2b2t · tianxiu2b2t · commit 93bb0ec5b28f · 2025-03-30T19:49:05.000+08:00
diff --git a/core/cluster.py b/core/cluster.py
@@ -589,7 +589,7 @@ async def upload_storage(
             retries = 0
             while 1:
                 try:
-                    await storage.storage.upload(f"download/{file.hash[:2]}/{file.hash}", tmp_file, size)
+                    await storage.storage.upload_download_file(f"{file.hash[:2]}/{file.hash}", tmp_file, size)
                     break
                 except:
                     if retries >= 10:
diff --git a/core/storage/abc.py b/core/storage/abc.py
@@ -156,6 +156,11 @@ async def upload(
     ):
         raise NotImplementedError
 
+    async def upload_download_file(self, path: str, tmp_file: tempfile._TemporaryFileWrapper, size: int):
+        if self.download_dir:
+            path = f"download/{path}"
+        await self.upload(f"download/{path}", tmp_file, size)
+
     async def get_response_file(
         self,
         hash: str
