phoenix/litellm-mirror
0
0
Fork 1
mirror of https://github.com/BerriAI/litellm.git synced 2025-04-27 11:43:54 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix(caching.py): add call type to service logger object

Browse source
This commit is contained in:
Krrish Dholakia 2024-04-18 16:53:34 -07:00
parent 51cc8dd95b
commit 27ea7b5fef
1 changed files with 14 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

18
litellm/caching.py
View file

@ -272,7 +272,9 @@ class RedisCache(BaseCache):
_duration = end_time - start_time _duration = end_time - start_time
asyncio.create_task( asyncio.create_task(
self.service_logger_obj.async_service_success_hook( self.service_logger_obj.async_service_success_hook(
service=ServiceTypes.REDIS, duration=_duration service=ServiceTypes.REDIS,
duration=_duration,
call_type="async_set_cache",
) )
) )
except Exception as e: except Exception as e:
@ -280,7 +282,10 @@ class RedisCache(BaseCache):
_duration = end_time - start_time _duration = end_time - start_time
asyncio.create_task( asyncio.create_task(
self.service_logger_obj.async_service_failure_hook( self.service_logger_obj.async_service_failure_hook(
service=ServiceTypes.REDIS, duration=_duration, error=e service=ServiceTypes.REDIS,
duration=_duration,
error=e,
call_type="async_set_cache",
) )
) )
# NON blocking - notify users Redis is throwing an exception # NON blocking - notify users Redis is throwing an exception
@ -321,7 +326,9 @@ class RedisCache(BaseCache):
_duration = end_time - start_time _duration = end_time - start_time
asyncio.create_task( asyncio.create_task(
self.service_logger_obj.async_service_success_hook( self.service_logger_obj.async_service_success_hook(
service=ServiceTypes.REDIS, duration=_duration service=ServiceTypes.REDIS,
duration=_duration,
call_type="async_set_cache_pipeline",
) )
) )
return results return results
@ -331,7 +338,10 @@ class RedisCache(BaseCache):
_duration = end_time - start_time _duration = end_time - start_time
asyncio.create_task( asyncio.create_task(
self.service_logger_obj.async_service_failure_hook( self.service_logger_obj.async_service_failure_hook(
service=ServiceTypes.REDIS, duration=_duration, error=e service=ServiceTypes.REDIS,
duration=_duration,
error=e,
call_type="async_set_cache_pipeline",
) )
) )