@@ -259,14 +259,14 @@ async def clean_chunks(self, upload_id: str, save_path: str):
259259 try :
260260 shutil .rmtree (chunk_dir )
261261 except Exception as e :
262- logger .info (f"清理本地分片目录失败: { e } " )
262+ logger .warning (f"清理本地分片目录失败: { e } " )
263263 # 清理父级 chunks 目录(如果为空)
264264 chunks_parent = chunk_dir .parent
265265 if chunks_parent .exists () and not any (chunks_parent .iterdir ()):
266266 try :
267267 chunks_parent .rmdir ()
268268 except Exception as e :
269- logger .info (f"清理 chunks 父目录失败: { e } " )
269+ logger .warning (f"清理 chunks 父目录失败: { e } " )
270270
271271 async def file_exists (self , save_path : str ) -> bool :
272272 """
@@ -537,7 +537,7 @@ async def clean_chunks(self, upload_id: str, save_path: str):
537537 Delete = {'Objects' : delete_objects }
538538 )
539539 except Exception as e :
540- logger .info (f"清理 S3 分片数据时出错: { e } " )
540+ logger .warning (f"清理 S3 分片数据时出错: { e } " )
541541
542542 async def generate_presigned_upload_url (self , save_path : str , expires_in : int = 900 ) -> Optional [str ]:
543543 """
@@ -865,7 +865,7 @@ async def clean_chunks(self, upload_id: str, save_path: str):
865865 try :
866866 await asyncio .to_thread (self ._delete_chunk_dir , chunk_dir )
867867 except Exception as e :
868- logger .info (f"清理 OneDrive 分片时出错: { e } " )
868+ logger .warning (f"清理 OneDrive 分片时出错: { e } " )
869869
870870 def _file_exists (self , save_path : str ) -> bool :
871871 """同步检查文件是否存在"""
@@ -1023,7 +1023,7 @@ async def clean_chunks(self, upload_id: str, save_path: str):
10231023 # OpenDAL 支持递归删除
10241024 await self .operator .remove_all (chunk_dir )
10251025 except Exception as e :
1026- logger .info (f"清理 OpenDAL 分片时出错: { e } " )
1026+ logger .warning (f"清理 OpenDAL 分片时出错: { e } " )
10271027
10281028 async def file_exists (self , save_path : str ) -> bool :
10291029 """
@@ -1334,16 +1334,16 @@ async def clean_chunks(self, upload_id: str, save_path: str):
13341334 file_url = self ._build_url (file_path )
13351335 async with session .delete (file_url ) as delete_resp :
13361336 if delete_resp .status not in (200 , 204 , 404 ):
1337- logger .info (f"删除分片文件失败: { file_path } " )
1337+ logger .warning (f"删除分片文件失败: { file_path } " )
13381338
13391339 # 删除分片目录
13401340 async with session .delete (chunk_dir_url ) as delete_resp :
13411341 if delete_resp .status not in (200 , 204 , 404 ):
1342- logger .info (f"删除分片目录失败: { chunk_dir_url } " )
1342+ logger .warning (f"删除分片目录失败: { chunk_dir_url } " )
13431343 else :
13441344 logger .info (f"分片目录不存在: { chunk_dir_url } " )
13451345 except Exception as e :
1346- logger .info (f"清理 WebDAV 分片时出错: { e } " )
1346+ logger .warning (f"清理 WebDAV 分片时出错: { e } " )
13471347
13481348 async def file_exists (self , save_path : str ) -> bool :
13491349 """
0 commit comments