From 01cfa647a29f4cd37892bcaa48e9cf84e3038839 Mon Sep 17 00:00:00 2001 From: Ankush Menat Date: Thu, 2 Jan 2025 14:26:56 +0530 Subject: [PATCH] fix: set/del locally too This is required if we do NOLOOP --- frappe/utils/redis_wrapper.py | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/frappe/utils/redis_wrapper.py b/frappe/utils/redis_wrapper.py index 8b1a24c084..384371280f 100644 --- a/frappe/utils/redis_wrapper.py +++ b/frappe/utils/redis_wrapper.py @@ -455,12 +455,14 @@ class _ClientCache: return val def set_value(self, key, val): - ret = self.redis.set_value(key, val) - return ret + key = self.redis.make_key(key) + self.redis.set_value(key, val, shared=True) + self.local_cache[key] = val def delete_value(self, key): - ret = self.redis.delete_value(key) - return ret + key = self.redis.make_key(key) + self.redis.delete_value(key, shared=True) + self.local_cache.pop(key, None) def run_invalidator_thread(self): self._watcher = self.monitor.pubsub()