python/aiogram
1
0
Fork 0
mirror of https://github.com/aiogram/aiogram.git synced 2026-04-08 16:37:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

More "await" in RedisStorage and RedisStorage2

Browse source
This commit is contained in:
Nikita 2019-03-10 22:04:19 +05:00
parent 843be46d19
commit 3a947407fc
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
aiogram/contrib/fsm_storage/redis.py
View file

@ -173,10 +173,10 @@ class RedisStorage(BaseStorage):
conn = await self.redis()
if full:
conn.execute('FLUSHDB')
await conn.execute('FLUSHDB')
else:
keys = await conn.execute('KEYS', 'fsm:*')
conn.execute('DEL', *keys)
await conn.execute('DEL', *keys)
def has_bucket(self):
return True
@ -350,10 +350,10 @@ class RedisStorage2(BaseStorage):
conn = await self.redis()
if full:
conn.flushdb()
await conn.flushdb()
else:
keys = await conn.keys(self.generate_key('*'))
conn.delete(*keys)
await conn.delete(*keys)
async def get_states_list(self) -> typing.List[typing.Tuple[int]]:
"""