fix [never_die]: avoid recomputating when using redis on dif processes

cachify/features/never_die.py

@@ -70,9 +70,18 @@ def revive(self):
 
 
 def _run_sync_function_and_cache(entry: NeverDieCacheEntry):
-    """Run a function and cache its result"""
     try:
+        cached = entry.config.storage.get(entry.cache_key, False)
+        if cached and cached.is_fresh(entry.ttl):
+            entry.reset()
+            return
+
         with entry.config.sync_lock(entry.cache_key):
+            cached = entry.config.storage.get(entry.cache_key, False)
+            if cached and cached.is_fresh(entry.ttl):
+                entry.reset()
+                return
+
             result = entry.function(*entry.args, **entry.kwargs)
             entry.config.storage.set(entry.cache_key, result, None)
             entry.reset()
@@ -86,9 +95,18 @@ def _run_sync_function_and_cache(entry: NeverDieCacheEntry):
 
 
 async def _run_async_function_and_cache(entry: NeverDieCacheEntry):
-    """Run a function and cache its result"""
     try:
+        cached = await entry.config.storage.aget(entry.cache_key, False)
+        if cached and cached.is_fresh(entry.ttl):
+            entry.reset()
+            return
+
         async with entry.config.async_lock(entry.cache_key):
+            cached = await entry.config.storage.aget(entry.cache_key, False)
+            if cached and cached.is_fresh(entry.ttl):
+                entry.reset()
+                return
+
             result = await entry.function(*entry.args, **entry.kwargs)
             await entry.config.storage.aset(entry.cache_key, result, None)
             entry.reset()

cachify/types/__init__.py

@@ -32,6 +32,9 @@ def is_expired(self) -> bool:
 
         return self.time() > self.expires_at
 
+    def is_fresh(self, ttl: float) -> bool:
+        return self.time() - self.cached_at < ttl
+
 
 @dataclass(frozen=True, slots=True)
 class CacheConfig:
@@ -49,6 +52,8 @@ class CacheEntryProtocol(Protocol):
 
     def is_expired(self) -> bool: ...
 
+    def is_fresh(self, ttl: float) -> bool: ...
+
 
 class CacheStorage(Protocol):
     """Protocol defining the interface for cache storage."""