remove fallback cache type when failed to connect to redis

langflow-ai · Jul 8, 2024 · 7624f28 · 7624f28
1 parent a4fda8a
commit 7624f28
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/backend/base/langflow/services/cache/factory.py b/src/backend/base/langflow/services/cache/factory.py
@@ -28,8 +28,9 @@ def create(self, settings_service: "SettingsService"):
             if redis_cache.is_connected():
                 logger.debug("Redis cache is connected")
                 return redis_cache
-            logger.warning("Redis cache is not connected, falling back to in-memory cache")
-            return AsyncInMemoryCache(expiration_time=settings_service.settings.redis_cache_expire)
+            else:
+                # do not attempt to fallback to another cache type
+                raise ConnectionError("Failed to connect to Redis cache")
 
         elif settings_service.settings.cache_type == "memory":
             return ThreadingInMemoryCache(expiration_time=settings_service.settings.cache_expire)