🤖 自动格式化代码 [skip ci]
This commit is contained in:
@@ -310,7 +310,9 @@ class NormalChat:
|
|||||||
try:
|
try:
|
||||||
# 在处理每个消息前检查停止状态
|
# 在处理每个消息前检查停止状态
|
||||||
if self._disabled:
|
if self._disabled:
|
||||||
logger.debug(f"[{self.stream_name}] 处理消息时检测到停用,跳过消息 {msg_id}")
|
logger.debug(
|
||||||
|
f"[{self.stream_name}] 处理消息时检测到停用,跳过消息 {msg_id}"
|
||||||
|
)
|
||||||
return
|
return
|
||||||
|
|
||||||
# 处理消息
|
# 处理消息
|
||||||
@@ -330,7 +332,7 @@ class NormalChat:
|
|||||||
finally:
|
finally:
|
||||||
# 无论如何都要清理消息
|
# 无论如何都要清理消息
|
||||||
self.interest_dict.pop(msg_id, None)
|
self.interest_dict.pop(msg_id, None)
|
||||||
|
|
||||||
tasks = [
|
tasks = [
|
||||||
process_and_acquire(msg_id, message, interest_value, is_mentioned)
|
process_and_acquire(msg_id, message, interest_value, is_mentioned)
|
||||||
for msg_id, (message, interest_value, is_mentioned) in items_to_process
|
for msg_id, (message, interest_value, is_mentioned) in items_to_process
|
||||||
|
|||||||
Reference in New Issue
Block a user