fix(close): 统一为异步方法以正确清理 aiohttp 会话和 diskcache 缓存

This commit is contained in:
SXP-Simon
2026-03-23 00:42:18 +08:00
committed by Helian Nuits
parent 4ffcb3065f
commit c65d26b4ba
2 changed files with 6 additions and 8 deletions
+1 -1
View File
@@ -255,7 +255,7 @@ class GroupDailyAnalysis(Star):
self.auto_scheduler = None # type: ignore
self.bot_manager = None # type: ignore
if self.report_generator:
self.report_generator.close()
await self.report_generator.close()
self.report_generator = None # type: ignore
self.config_manager = None # type: ignore
self.message_processing_service = None # type: ignore
+5 -7
View File
@@ -42,12 +42,6 @@ class ReportGenerator(IReportGenerator):
)
self._avatar_session = None
async def close(self):
"""关闭资源"""
if self._avatar_session:
await self._avatar_session.close()
self._avatar_session = None
async def generate_image_report(
self,
analysis_result: dict,
@@ -677,8 +671,12 @@ class ReportGenerator(IReportGenerator):
b64 = base64.b64encode(svg.encode("utf-8")).decode("utf-8")
return f"data:image/svg+xml;base64,{b64}"
def close(self):
async def close(self):
"""释放资源,关闭缓存和 session"""
if self._avatar_session:
await self._avatar_session.close()
self._avatar_session = None
try:
if self._avatar_cache:
self._avatar_cache.close()