(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) |
| 113 | |
| 114 | async def unlock(self): |
| 115 | await redis_conn.pop(key=self.__lock_redis_key()) |
no test coverage detected