working, track raw request

This commit is contained in:
Ishaan Jaff 2025-02-28 10:09:16 -08:00
parent d3171a94ef
commit d0d9236947
2 changed files with 10 additions and 6 deletions

View file

@ -48,9 +48,13 @@ class _ProxyDBLogger(CustomLogger):
)
_metadata["user_api_key"] = user_api_key_dict.api_key
_metadata["status"] = "failure"
existing_metadata: dict = request_data.get("metadata", None) or {}
existing_metadata.update(_metadata)
existing_metadata["proxy_server_request"] = (
request_data.get("proxy_server_request", {}) or {}
)
request_data["litellm_params"] = {}
request_data["litellm_params"]["metadata"] = _metadata
# print("failure kwargs=", json.dumps(request_data, indent=4, default=str))
request_data["litellm_params"]["metadata"] = existing_metadata
await update_database(
token=user_api_key_dict.api_key,

View file

@ -298,15 +298,15 @@ def _get_messages_for_spend_logs_payload(
standard_logging_payload: Optional[StandardLoggingPayload],
metadata: Optional[dict] = None,
) -> str:
if standard_logging_payload is None:
return "{}"
if _should_store_prompts_and_responses_in_spend_logs():
metadata = metadata or {}
if metadata.get("status", None) == "failure":
_proxy_server_request = metadata.get("proxy_server_request", {})
_request_body = _proxy_server_request.get("request", {})
return json.dumps(_request_body)
_request_body = _proxy_server_request.get("body", {}) or {}
return json.dumps(_request_body, default=str)
else:
if standard_logging_payload is None:
return "{}"
return json.dumps(standard_logging_payload.get("messages", {}))
return "{}"