From 83412fa9f141d4b57f6016bfd4cdc9ca98bd5c5d Mon Sep 17 00:00:00 2001
From: Benedikt Bartscher <bb@senbax.de>
Date: Thu, 7 Nov 2024 21:08:35 +0100
Subject: [PATCH] prefix all redis keys

---
 reflex/state.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/reflex/state.py b/reflex/state.py
index 81a054173..657827b88 100644
--- a/reflex/state.py
+++ b/reflex/state.py
@@ -3403,7 +3403,7 @@ class StateManagerRedis(StateManager):
             while not state_is_locked:
                 # wait for the lock to be released
                 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
                     message = await pubsub.get_message(
                         ignore_subscribe_messages=True,
@@ -3444,7 +3444,7 @@ class StateManagerRedis(StateManager):
         finally:
             if state_is_locked:
                 # only delete our lock
-                await self.redis.delete(lock_key)
+                await self.redis.delete(prefix_redis_token(lock_key))
 
     async def close(self):
         """Explicitly close the redis connection and connection_pool.