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

support dynamic retry policies

Browse source
This commit is contained in:
Ishaan Jaff 2024-05-04 18:10:15 -07:00
parent b8f8b6c31b
commit 433333400f
2 changed files with 23 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

34
litellm/router.py
View file

@ -1509,10 +1509,11 @@ class Router:
)
await asyncio.sleep(_timeout)
## LOGGING
if self.retry_policy is not None:
if self.retry_policy is not None or kwargs.get("retry_policy") is not None:
# get num_retries from retry policy
_retry_policy_retries = self.get_num_retries_from_retry_policy(
exception=original_exception
exception=original_exception,
dynamic_retry_policy=kwargs.get("retry_policy"),
)
if _retry_policy_retries is not None:
num_retries = _retry_policy_retries
@ -3267,7 +3268,9 @@ class Router:
except Exception as e:
verbose_router_logger.error(f"Error in _track_deployment_metrics: {str(e)}")
def get_num_retries_from_retry_policy(self, exception: Exception):
def get_num_retries_from_retry_policy(
self, exception: Exception, dynamic_retry_policy: Optional[RetryPolicy] = None
):
"""
BadRequestErrorRetries: Optional[int] = None
AuthenticationErrorRetries: Optional[int] = None
@ -3276,33 +3279,36 @@ class Router:
ContentPolicyViolationErrorRetries: Optional[int] = None
"""
# if we can find the exception then in the retry policy -> return the number of retries
if self.retry_policy is None:
retry_policy = self.retry_policy
if dynamic_retry_policy is not None:
retry_policy = dynamic_retry_policy
if retry_policy is None:
return None
if (
isinstance(exception, litellm.BadRequestError)
and self.retry_policy.BadRequestErrorRetries is not None
and retry_policy.BadRequestErrorRetries is not None
):
return self.retry_policy.BadRequestErrorRetries
return retry_policy.BadRequestErrorRetries
if (
isinstance(exception, litellm.AuthenticationError)
and self.retry_policy.AuthenticationErrorRetries is not None
and retry_policy.AuthenticationErrorRetries is not None
):
return self.retry_policy.AuthenticationErrorRetries
return retry_policy.AuthenticationErrorRetries
if (
isinstance(exception, litellm.Timeout)
and self.retry_policy.TimeoutErrorRetries is not None
and retry_policy.TimeoutErrorRetries is not None
):
return self.retry_policy.TimeoutErrorRetries
return retry_policy.TimeoutErrorRetries
if (
isinstance(exception, litellm.RateLimitError)
and self.retry_policy.RateLimitErrorRetries is not None
and retry_policy.RateLimitErrorRetries is not None
):
return self.retry_policy.RateLimitErrorRetries
return retry_policy.RateLimitErrorRetries
if (
isinstance(exception, litellm.ContentPolicyViolationError)
and self.retry_policy.ContentPolicyViolationErrorRetries is not None
and retry_policy.ContentPolicyViolationErrorRetries is not None
):
return self.retry_policy.ContentPolicyViolationErrorRetries
return retry_policy.ContentPolicyViolationErrorRetries
def flush_cache(self):
litellm.cache = None