fix: set/del locally too

This is required if we do NOLOOP
This commit is contained in:
Ankush Menat 2025-01-02 14:26:56 +05:30
parent e7139a1395
commit 01cfa647a2

View file

@ -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()