From 16855d1de92b74c9455da9b73c6be9633b7d5ae1 Mon Sep 17 00:00:00 2001 From: harold Date: Mon, 5 May 2025 17:07:03 +0500 Subject: [PATCH] add fix --- telegram-application/src/core/tg_service/service.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/telegram-application/src/core/tg_service/service.py b/telegram-application/src/core/tg_service/service.py index 96bb5b5..f72e4ba 100644 --- a/telegram-application/src/core/tg_service/service.py +++ b/telegram-application/src/core/tg_service/service.py @@ -1,3 +1,4 @@ +import asyncio import uuid from pyrogram.types.user_and_chats import User as PyroUser, Chat as PyroChat @@ -6,11 +7,13 @@ from src.core.database import TgChat, User from src.core.rabbitmq.connect import message_handler_publisher from src.core.redis_helper.redis_connect import redis_client from src.core.tg_service.constants import MESSAGE_CHANG_SIZE -from src.core.tg_service.messages_handler import lock from src.core.tg_service.schemas import UserFromMessageSchema, MessagesForSendToWorkersSchema, MessageFromChatSchema from src.core.database.connect import db_helper from src.core.tg_service import crud as tg_crud +lock = asyncio.Lock() + + async def check_user_exists( user_pyrogram: PyroUser,