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__(