phoenix/litellm-mirror
0
0
Fork 1
mirror of https://github.com/BerriAI/litellm.git synced 2025-04-25 10:44:24 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

(fix) redis 6.2 version incompatibility issue

Browse source
This commit is contained in:
Ishaan Jaff 2024-03-20 09:38:21 -07:00
parent ca970a90c4
commit 7b29273b14
1 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

9
litellm/caching.py
View file

@ -111,6 +111,7 @@ class RedisCache(BaseCache):
self.redis_client = get_redis_client(**redis_kwargs)
self.redis_kwargs = redis_kwargs
self.async_redis_conn_pool = get_redis_connection_pool(**redis_kwargs)
self.redis_version = self.redis_client.info()["redis_version"]
def init_async_client(self):
from ._redis import get_redis_async_client
@ -121,7 +122,9 @@ class RedisCache(BaseCache):
def set_cache(self, key, value, **kwargs):
ttl = kwargs.get("ttl", None)
print_verbose(f"Set Redis Cache: key: {key}\nValue {value}\nttl={ttl}")
print_verbose(
f"Set Redis Cache: key: {key}\nValue {value}\nttl={ttl}, redis_version={self.redis_version}"
)
try:
self.redis_client.set(name=key, value=str(value), ex=ttl)
except Exception as e:
@ -148,9 +151,7 @@ class RedisCache(BaseCache):
f"Set ASYNC Redis Cache: key: {key}\nValue {value}\nttl={ttl}"
)
try:
await redis_client.set(
name=key, value=json.dumps(value), ex=ttl, get=True
)
await redis_client.set(name=key, value=json.dumps(value), ex=ttl)
print_verbose(
f"Successfully Set ASYNC Redis Cache: key: {key}\nValue {value}\nttl={ttl}"
)