From 7624f287e1dc7c2d22815da92bc8deb0fc81e0f8 Mon Sep 17 00:00:00 2001 From: ming luo Date: Sun, 7 Jul 2024 22:40:42 -0400 Subject: [PATCH] remove fallback cache type when failed to connect to redis --- src/backend/base/langflow/services/cache/factory.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/backend/base/langflow/services/cache/factory.py b/src/backend/base/langflow/services/cache/factory.py index 3c938f8a2e9..5cc6b12afe0 100644 --- 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)