(self)
| 106 | return f"chat:{self.assistant_id}:{self.chat_id}:lock" |
| 107 | |
| 108 | async def is_chat_locked(self): |
| 109 | return await redis_conn.get_int(key=self.__lock_redis_key()) == 1 |
| 110 | |
| 111 | async def lock(self): |
| 112 | await redis_conn.set_int(key=self.__lock_redis_key(), value=1, expire=120) |
no test coverage detected