fix: Fix redis client starting even with LETTA_REDIS_PORT and LETTA_REDIS_HOST are unset (#2833)

This commit is contained in:
Matthew Zhou
2025-06-15 20:48:33 -07:00
committed by GitHub
parent 69434781be
commit dc80d62deb

View File

@@ -290,12 +290,17 @@ async def get_redis_client() -> AsyncRedisClient:
try:
from letta.settings import settings
_client_instance = AsyncRedisClient(
host=settings.redis_host or "localhost",
port=settings.redis_port or 6379,
)
await _client_instance.wait_for_ready(timeout=5)
logger.info("Redis client initialized")
# If Redis settings are not configured, use noop client
if settings.redis_host is None or settings.redis_port is None:
logger.info("Redis not configured, using noop client")
_client_instance = NoopAsyncRedisClient()
else:
_client_instance = AsyncRedisClient(
host=settings.redis_host,
port=settings.redis_port,
)
await _client_instance.wait_for_ready(timeout=5)
logger.info("Redis client initialized")
except Exception as e:
logger.warning(f"Failed to initialize Redis: {e}")
_client_instance = NoopAsyncRedisClient()