From 4f3e653e1fcd8158c7d3bb3142d8038ed6168257 Mon Sep 17 00:00:00 2001
From: SengokuCola <1026294844@qq.com>
Date: Thu, 10 Jul 2025 03:20:31 +0800
Subject: [PATCH] Update normal_chat.py

---
 src/chat/normal_chat/normal_chat.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/chat/normal_chat/normal_chat.py b/src/chat/normal_chat/normal_chat.py
index 43abc3e1a..883765c72 100644
--- a/src/chat/normal_chat/normal_chat.py
+++ b/src/chat/normal_chat/normal_chat.py
@@ -304,7 +304,9 @@ class NormalChat:
 
                             semaphore = asyncio.Semaphore(5)
 
-                            async def process_and_acquire(msg_id, message, interest_value, is_mentioned):
+                            async def process_and_acquire(
+                                msg_id, message, interest_value, is_mentioned, semaphore=semaphore
+                            ):
                                 """处理单个兴趣消息并管理信号量"""
                                 async with semaphore:
                                     try: