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

fix update_cache function

Browse source
This commit is contained in:
Ishaan Jaff 2024-06-20 17:27:25 -07:00
parent 0003de41c1
commit c4b34946ed
1 changed files with 12 additions and 35 deletions
Download patch file Download diff file Expand all files Collapse all files

41
litellm/proxy/proxy_server.py
View file

@ -802,7 +802,7 @@ async def update_database(
+ prisma_client.key_list_transactons.get(hashed_token, 0) + prisma_client.key_list_transactons.get(hashed_token, 0)
) )
except Exception as e: except Exception as e:
verbose_proxy_logger.info( verbose_proxy_logger.error(
f"Update Key DB Call failed to execute - {str(e)}\n{traceback.format_exc()}" f"Update Key DB Call failed to execute - {str(e)}\n{traceback.format_exc()}"
) )
raise e raise e
@ -936,7 +936,6 @@ async def update_cache(
f"_update_key_cache: existing spend: {existing_spend_obj}" f"_update_key_cache: existing spend: {existing_spend_obj}"
) )
if existing_spend_obj is None: if existing_spend_obj is None:
# print("existing_spend_obj is None adding a bad value to use api key cache")
return return
else: else:
existing_spend = existing_spend_obj.spend existing_spend = existing_spend_obj.spend
@ -1019,23 +1018,12 @@ async def update_cache(
continue continue
existing_spend_obj = await user_api_key_cache.async_get_cache(key=_id) existing_spend_obj = await user_api_key_cache.async_get_cache(key=_id)
if existing_spend_obj is None: if existing_spend_obj is None:
# if user does not exist in LiteLLM_UserTable, create a new user # do nothing if there is no cache value
existing_spend = 0 return
max_user_budget = None
if litellm.max_user_budget is not None:
max_user_budget = litellm.max_user_budget
existing_spend_obj = LiteLLM_UserTable(
user_id=_id,
spend=0,
max_budget=max_user_budget,
user_email=None,
)
verbose_proxy_logger.debug( verbose_proxy_logger.debug(
f"_update_user_db: existing spend: {existing_spend_obj}; response_cost: {response_cost}" f"_update_user_db: existing spend: {existing_spend_obj}; response_cost: {response_cost}"
) )
if existing_spend_obj is None:
existing_spend = 0
else:
if isinstance(existing_spend_obj, dict): if isinstance(existing_spend_obj, dict):
existing_spend = existing_spend_obj["spend"] existing_spend = existing_spend_obj["spend"]
else: else:
@ -1057,9 +1045,8 @@ async def update_cache(
key="{}:spend".format(litellm_proxy_admin_name) key="{}:spend".format(litellm_proxy_admin_name)
) )
if global_proxy_spend is None: if global_proxy_spend is None:
await user_api_key_cache.async_set_cache( # do nothing if not in cache
key="{}:spend".format(litellm_proxy_admin_name), value=response_cost return
)
elif response_cost is not None and global_proxy_spend is not None: elif response_cost is not None and global_proxy_spend is not None:
increment = global_proxy_spend + response_cost increment = global_proxy_spend + response_cost
await user_api_key_cache.async_set_cache( await user_api_key_cache.async_set_cache(
@ -1081,19 +1068,8 @@ async def update_cache(
existing_spend_obj = await user_api_key_cache.async_get_cache(key=_id) existing_spend_obj = await user_api_key_cache.async_get_cache(key=_id)
if existing_spend_obj is None: if existing_spend_obj is None:
# if user does not exist in LiteLLM_UserTable, create a new user # if user does not exist in LiteLLM_UserTable, create a new user
existing_spend = 0 # do nothing if end-user not in api key cache
max_user_budget = None return
max_end_user_budget = None
if litellm.max_end_user_budget is not None:
max_end_user_budget = litellm.max_end_user_budget
existing_spend_obj = LiteLLM_EndUserTable(
user_id=end_user_id,
spend=0,
blocked=False,
litellm_budget_table=LiteLLM_BudgetTable(
max_budget=max_end_user_budget
),
)
verbose_proxy_logger.debug( verbose_proxy_logger.debug(
f"_update_end_user_db: existing spend: {existing_spend_obj}; response_cost: {response_cost}" f"_update_end_user_db: existing spend: {existing_spend_obj}; response_cost: {response_cost}"
) )
@ -1131,6 +1107,7 @@ async def update_cache(
await user_api_key_cache.async_get_cache(key=_id) await user_api_key_cache.async_get_cache(key=_id)
) )
if existing_spend_obj is None: if existing_spend_obj is None:
# do nothing if team not in api key cache
return return
verbose_proxy_logger.debug( verbose_proxy_logger.debug(
f"_update_team_db: existing spend: {existing_spend_obj}; response_cost: {response_cost}" f"_update_team_db: existing spend: {existing_spend_obj}; response_cost: {response_cost}"