add fix

2025-05-05 16:27:24 +05:00 · 2025-05-05 16:27:24 +05:00 · 55c2ab61d0
commit 55c2ab61d0
parent e0ef6a3bf2
1 changed files with 6 additions and 6 deletions
--- a/telegram-application/src/core/tg_service/messages_handler.py
+++ b/telegram-application/src/core/tg_service/messages_handler.py
@ -31,10 +31,10 @@ async def message_listener(client: Client, message: Message):
            text=message.text,
            message_time=message.date,
        )
-
-        await check_chunk_state_and_publish(
-            data=DATA,
-            message_schema=message_schema,
-            chat_id=message.chat.id,
-        )
+        async with lock:
+            await check_chunk_state_and_publish(
+                data=DATA,
+                message_schema=message_schema,
+                chat_id=message.chat.id,
+            )