From 55c2ab61d02fd4f63a603765da0bcd91d3ab3842 Mon Sep 17 00:00:00 2001 From: harold Date: Mon, 5 May 2025 16:27:24 +0500 Subject: [PATCH] add fix --- .../src/core/tg_service/messages_handler.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/telegram-application/src/core/tg_service/messages_handler.py b/telegram-application/src/core/tg_service/messages_handler.py index e3e3653..c689744 100644 --- 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, + )