From e74060479862fb23bb48f790ee95ea00c20f757f Mon Sep 17 00:00:00 2001 From: Soulter <905617992@qq.com> Date: Thu, 19 Mar 2026 19:01:29 +0800 Subject: [PATCH] chore: ruff format --- astrbot/core/pipeline/scheduler.py | 4 +--- astrbot/core/platform/sources/wecom_ai_bot/wecomai_event.py | 1 + 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/astrbot/core/pipeline/scheduler.py b/astrbot/core/pipeline/scheduler.py index 4af41eef2..ca69b8475 100644 --- a/astrbot/core/pipeline/scheduler.py +++ b/astrbot/core/pipeline/scheduler.py @@ -87,9 +87,7 @@ class PipelineScheduler: await self._process_stages(event) # 发送一个空消息, 以便于后续的处理 - if ( - isinstance(event, WebChatMessageEvent | WecomAIBotMessageEvent) - ): + if isinstance(event, WebChatMessageEvent | WecomAIBotMessageEvent): await event.send(None) logger.debug("pipeline 执行完毕。") diff --git a/astrbot/core/platform/sources/wecom_ai_bot/wecomai_event.py b/astrbot/core/platform/sources/wecom_ai_bot/wecomai_event.py index ec1c7bffa..f27d4671e 100644 --- a/astrbot/core/platform/sources/wecom_ai_bot/wecomai_event.py +++ b/astrbot/core/platform/sources/wecom_ai_bot/wecomai_event.py @@ -14,6 +14,7 @@ from .wecomai_webhook import WecomAIBotWebhookClient class WecomAIBotMessageEvent(AstrMessageEvent): """企业微信智能机器人消息事件""" + STREAM_FLUSH_INTERVAL = 0.5 def __init__(