fix(utils.py): correctly re-raise azure api connection error

'
This commit is contained in:
Krrish Dholakia 2024-07-29 12:28:12 -07:00
parent 63531a9824
commit 59384c84a5
3 changed files with 17 additions and 8 deletions

View file

@ -1,12 +1,12 @@
repos: repos:
- repo: local - repo: local
hooks: hooks:
- id: mypy # - id: mypy
name: mypy # name: mypy
entry: python3 -m mypy --ignore-missing-imports # entry: python3 -m mypy --ignore-missing-imports
language: system # language: system
types: [python] # types: [python]
files: ^litellm/ # files: ^litellm/
- id: isort - id: isort
name: isort name: isort
entry: isort entry: isort

View file

@ -582,7 +582,7 @@ class APIConnectionError(openai.APIConnectionError): # type: ignore
message, message,
llm_provider, llm_provider,
model, model,
request: httpx.Request, request: Optional[httpx.Request] = None,
litellm_debug_info: Optional[str] = None, litellm_debug_info: Optional[str] = None,
max_retries: Optional[int] = None, max_retries: Optional[int] = None,
num_retries: Optional[int] = None, num_retries: Optional[int] = None,
@ -592,9 +592,10 @@ class APIConnectionError(openai.APIConnectionError): # type: ignore
self.model = model self.model = model
self.status_code = 500 self.status_code = 500
self.litellm_debug_info = litellm_debug_info self.litellm_debug_info = litellm_debug_info
self.request = httpx.Request(method="POST", url="https://api.openai.com/v1")
self.max_retries = max_retries self.max_retries = max_retries
self.num_retries = num_retries self.num_retries = num_retries
super().__init__(message=self.message, request=request) super().__init__(message=self.message, request=self.request)
def __str__(self): def __str__(self):
_message = self.message _message = self.message

View file

@ -7866,6 +7866,14 @@ def exception_type(
model=model, model=model,
litellm_debug_info=extra_information, litellm_debug_info=extra_information,
) )
elif "Connection error" in error_str:
exception_mapping_worked = True
raise APIConnectionError(
message=f"{exception_provider} APIConnectionError - {message}",
llm_provider=custom_llm_provider,
model=model,
litellm_debug_info=extra_information,
)
elif hasattr(original_exception, "status_code"): elif hasattr(original_exception, "status_code"):
exception_mapping_worked = True exception_mapping_worked = True
if original_exception.status_code == 400: if original_exception.status_code == 400: