Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 4 additions & 2 deletions astrbot/core/pipeline/scheduler.py
Original file line number Diff line number Diff line change
Expand Up @@ -86,8 +86,10 @@ async def execute(self, event: AstrMessageEvent) -> None:
try:
await self._process_stages(event)

# 如果没有发送操作, 则发送一个空消息, 以便于后续的处理
if isinstance(event, WebChatMessageEvent | WecomAIBotMessageEvent):
# 发送一个空消息, 以便于后续的处理
if (
isinstance(event, WebChatMessageEvent | WecomAIBotMessageEvent)
):
Comment thread
Soulter marked this conversation as resolved.
await event.send(None)

logger.debug("pipeline 执行完毕。")
Expand Down
2 changes: 2 additions & 0 deletions astrbot/core/platform/sources/wecom_ai_bot/wecomai_event.py
Original file line number Diff line number Diff line change
Expand Up @@ -135,6 +135,8 @@ def _extract_plain_text_from_chain(message_chain: MessageChain | None) -> str:

async def send(self, message: MessageChain | None) -> None:
"""发送消息"""
if message is None:
return
raw = self.message_obj.raw_message
assert isinstance(raw, dict), (
"wecom_ai_bot platform event raw_message should be a dict"
Expand Down