jyapayne/langflow
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

BUG FIX 2152

Browse source 
When the cache expires, deleting the key from the cache will attempt to acquire a lock, which is not reentrant at this point, leading to suspension.
This commit is contained in:
mmdsnb 2024-06-19 17:47:20 +08:00 • committed by Gabriel Luiz Freitas Almeida
commit f18ca3d8a1
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/backend/base/langflow/services/cache/service.py vendored
View file

@ -350,7 +350,7 @@ class AsyncInMemoryCache(AsyncBaseCacheService, Service):
return pickle.loads(item["value"]) if isinstance(item["value"], bytes) else item["value"] return pickle.loads(item["value"]) if isinstance(item["value"], bytes) else item["value"]
else: else:
logger.info(f"Cache item for key '{key}' has expired and will be deleted.") logger.info(f"Cache item for key '{key}' has expired and will be deleted.")
await self.delete(key) # Log before deleting the expired item await self._delete(key) # Log before deleting the expired item
return CACHE_MISS return CACHE_MISS
async def set(self, key, value, lock: Optional[asyncio.Lock] = None): async def set(self, key, value, lock: Optional[asyncio.Lock] = None):