laipeng/reflex
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

prefix all redis keys

Browse Source
This commit is contained in:
Benedikt Bartscher 2024-11-07 21:08:35 +01:00
parent 387efeb39d
commit 83412fa9f1
No known key found for this signature in database
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
reflex/state.py
View File

@ -3403,7 +3403,7 @@ class StateManagerRedis(StateManager):
while not state_is_locked: while not state_is_locked:
# wait for the lock to be released # wait for the lock to be released
while True: while True:
if not await self.redis.exists(lock_key): if not await self.redis.exists(prefix_redis_token(lock_key)):
break # key was removed, try to get the lock again break # key was removed, try to get the lock again
message = await pubsub.get_message( message = await pubsub.get_message(
ignore_subscribe_messages=True, ignore_subscribe_messages=True,
@ -3444,7 +3444,7 @@ class StateManagerRedis(StateManager):
finally: finally:
if state_is_locked: if state_is_locked:
# only delete our lock # only delete our lock
await self.redis.delete(lock_key) await self.redis.delete(prefix_redis_token(lock_key))
async def close(self): async def close(self):
"""Explicitly close the redis connection and connection_pool. """Explicitly close the redis connection and connection_pool.