From f2b4c1691979ad9d85170d5eb3259d89349a39e9 Mon Sep 17 00:00:00 2001 From: SXP-Simon Date: Thu, 12 Mar 2026 18:05:01 +0800 Subject: [PATCH] fix(ruff) --- main.py | 8 ++++---- src/infrastructure/reporting/dispatcher.py | 12 +++--------- src/infrastructure/scheduler/auto_scheduler.py | 1 + 3 files changed, 8 insertions(+), 13 deletions(-) diff --git a/main.py b/main.py index da0212c..2e93d7f 100644 --- a/main.py +++ b/main.py @@ -478,12 +478,12 @@ class GroupDailyAnalysis(Star): pass # 设置 TraceID (语义化格式: manual_群名_HHmm) - trace_id = TraceContext.generate(prefix="manual", group_name=group_name or group_id) + trace_id = TraceContext.generate( + prefix="manual", group_name=group_name or group_id + ) TraceContext.set(trace_id) - yield event.plain_result( - "🔍 正在启动跨平台分析引擎,正在拉取最近消息..." - ) + yield event.plain_result("🔍 正在启动跨平台分析引擎,正在拉取最近消息...") try: # 调用 DDD 应用级服务 diff --git a/src/infrastructure/reporting/dispatcher.py b/src/infrastructure/reporting/dispatcher.py index a96feb1..4201a08 100644 --- a/src/infrastructure/reporting/dispatcher.py +++ b/src/infrastructure/reporting/dispatcher.py @@ -50,13 +50,9 @@ class ReportDispatcher: success = await self._dispatch_text(group_id, analysis_result, platform_id) if success: - logger.info( - f"[{trace_id}] 群 {group_id} 的报告分发成功" - ) + logger.info(f"[{trace_id}] 群 {group_id} 的报告分发成功") else: - logger.warning( - f"[{trace_id}] 群 {group_id} 的报告分发失败" - ) + logger.warning(f"[{trace_id}] 群 {group_id} 的报告分发失败") async def _dispatch_image( self, group_id: str, analysis_result: dict[str, Any], platform_id: str | None @@ -64,9 +60,7 @@ class ReportDispatcher: trace_id = TraceContext.get() # 1. 检查渲染函数 if not self._html_render_func: - logger.warning( - f"[{trace_id}] 未设置 HTML 渲染函数,回退到文本模式。" - ) + logger.warning(f"[{trace_id}] 未设置 HTML 渲染函数,回退到文本模式。") return await self._dispatch_text(group_id, analysis_result, platform_id) # 2. 生成图片 diff --git a/src/infrastructure/scheduler/auto_scheduler.py b/src/infrastructure/scheduler/auto_scheduler.py index 860f283..e46f14d 100644 --- a/src/infrastructure/scheduler/auto_scheduler.py +++ b/src/infrastructure/scheduler/auto_scheduler.py @@ -113,6 +113,7 @@ class AutoScheduler: except Exception as e: logger.error(f"❌ 获取平台ID失败: {e}") return None + async def _get_group_name_safe( self, group_id: str, platform_id: str | None = None ) -> str: