diff --git a/litellm/utils.py b/litellm/utils.py index e8740e8aae..f7cc5d2a54 100644 --- a/litellm/utils.py +++ b/litellm/utils.py @@ -8423,72 +8423,3 @@ def print_args_passed_to_litellm(original_function, args, kwargs): except: # This should always be non blocking pass - - -def get_logging_payload(kwargs, response_obj, start_time, end_time): - from litellm.proxy._types import LiteLLM_SpendLogs - from pydantic import Json - - if kwargs == None: - kwargs = {} - # standardize this function to be used across, s3, dynamoDB, langfuse logging - litellm_params = kwargs.get("litellm_params", {}) - metadata = ( - litellm_params.get("metadata", {}) or {} - ) # if litellm_params['metadata'] == None - messages = kwargs.get("messages") - optional_params = kwargs.get("optional_params", {}) - call_type = kwargs.get("call_type", "litellm.completion") - cache_hit = kwargs.get("cache_hit", False) - usage = response_obj["usage"] - id = response_obj.get("id", str(uuid.uuid4())) - api_key = metadata.get("user_api_key", "") - - payload = { - "request_id": id, - "call_type": call_type, - "api_key": api_key, - "cache_hit": cache_hit, - "startTime": start_time, - "endTime": end_time, - "model": kwargs.get("model", ""), - "user": kwargs.get("user", ""), - "modelParameters": optional_params, - "messages": messages, - "response": response_obj, - "usage": usage, - "metadata": metadata, - } - - json_fields = [ - field - for field, field_type in LiteLLM_SpendLogs.__annotations__.items() - if field_type == Json or field_type == Optional[Json] - ] - str_fields = [ - field - for field, field_type in LiteLLM_SpendLogs.__annotations__.items() - if field_type == str or field_type == Optional[str] - ] - datetime_fields = [ - field - for field, field_type in LiteLLM_SpendLogs.__annotations__.items() - if field_type == datetime - ] - - for param in json_fields: - if param in payload and type(payload[param]) != Json: - if type(payload[param]) == ModelResponse: - payload[param] = payload[param].model_dump_json() - if type(payload[param]) == EmbeddingResponse: - payload[param] = payload[param].model_dump_json() - elif type(payload[param]) == Usage: - payload[param] = payload[param].model_dump_json() - else: - payload[param] = json.dumps(payload[param]) - - for param in str_fields: - if param in payload and type(payload[param]) != str: - payload[param] = str(payload[param]) - - return payload