diff --git a/src/openai/_base_client.py b/src/openai/_base_client.py index cf4571bf45..feb187df80 100644 --- a/src/openai/_base_client.py +++ b/src/openai/_base_client.py @@ -1000,6 +1000,10 @@ def request( log.debug("Sending HTTP Request: %s %s", request.method, request.url) + if log.isEnabledFor(logging.DEBUG): + if request.content: + log.debug("Request body: %s", request.content.decode("utf-8", errors="replace")) + response = None try: response = self._client.send( @@ -1046,6 +1050,10 @@ def request( ) log.debug("request_id: %s", response.headers.get("x-request-id")) + if log.isEnabledFor(logging.DEBUG): + if not stream and not self._should_stream_response_body(request=request): + log.debug("Response body: %s", response.text) + try: response.raise_for_status() except httpx.HTTPStatusError as err: # thrown on 4xx and 5xx status code @@ -1599,6 +1607,10 @@ async def request( log.debug("Sending HTTP Request: %s %s", request.method, request.url) + if log.isEnabledFor(logging.DEBUG): + if request.content: + log.debug("Request body: %s", request.content.decode("utf-8", errors="replace")) + response = None try: response = await self._client.send( @@ -1645,6 +1657,10 @@ async def request( ) log.debug("request_id: %s", response.headers.get("x-request-id")) + if log.isEnabledFor(logging.DEBUG): + if not stream and not self._should_stream_response_body(request=request): + log.debug("Response body: %s", response.text) + try: response.raise_for_status() except httpx.HTTPStatusError as err: # thrown on 4xx and 5xx status code