Skip to content

Commit bcf665c

Browse files
committed
Fix ruff lint and format issues in retry-after code
Signed-off-by: debu-sinha <debusinha2009@gmail.com>
1 parent 09016b3 commit bcf665c

File tree

4 files changed

+20
-8
lines changed

4 files changed

+20
-8
lines changed

llama-index-integrations/embeddings/llama-index-embeddings-openai/llama_index/embeddings/openai/utils.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,8 @@
4040

4141

4242
class _WaitRetryAfter(wait_base):
43-
"""Wait strategy that respects the Retry-After header on RateLimitError.
43+
"""
44+
Wait strategy that respects the Retry-After header on RateLimitError.
4445
4546
When the last exception is an ``openai.RateLimitError`` whose HTTP response
4647
contains a ``Retry-After`` header, the wait time is taken from that header
@@ -61,7 +62,8 @@ def __call__(self, retry_state: RetryCallState) -> float:
6162

6263

6364
def _parse_retry_after(exc: openai.RateLimitError) -> Optional[float]:
64-
"""Extract the Retry-After value (in seconds) from a RateLimitError.
65+
"""
66+
Extract the Retry-After value (in seconds) from a RateLimitError.
6567
6668
Returns ``None`` when the header is missing or cannot be parsed.
6769
"""

llama-index-integrations/embeddings/llama-index-embeddings-openai/tests/test_retry_after.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,9 @@ def test_parse_retry_after_missing_header():
6666

6767

6868
def test_parse_retry_after_non_numeric():
69-
exc = _make_rate_limit_error(headers={"Retry-After": "Wed, 21 Oct 2025 07:28:00 GMT"})
69+
exc = _make_rate_limit_error(
70+
headers={"Retry-After": "Wed, 21 Oct 2025 07:28:00 GMT"}
71+
)
7072
assert _parse_retry_after(exc) is None
7173

7274

@@ -127,7 +129,9 @@ def test_wait_retry_after_falls_back_for_non_rate_limit_error():
127129
fallback = MagicMock(return_value=7.0)
128130
strategy = _WaitRetryAfter(fallback)
129131

130-
exc = openai.APITimeoutError(request=httpx.Request("POST", "https://api.openai.com"))
132+
exc = openai.APITimeoutError(
133+
request=httpx.Request("POST", "https://api.openai.com")
134+
)
131135
rs = _make_retry_state(exc)
132136
assert strategy(rs) == 7.0
133137
fallback.assert_called_once_with(rs)

llama-index-integrations/llms/llama-index-llms-openai/llama_index/llms/openai/utils.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -259,7 +259,8 @@ def is_json_schema_supported(model: str) -> bool:
259259

260260

261261
class _WaitRetryAfter(wait_base):
262-
"""Wait strategy that respects the Retry-After header on RateLimitError.
262+
"""
263+
Wait strategy that respects the Retry-After header on RateLimitError.
263264
264265
When the last exception is an ``openai.RateLimitError`` whose HTTP response
265266
contains a ``Retry-After`` header, the wait time is taken from that header
@@ -280,7 +281,8 @@ def __call__(self, retry_state: RetryCallState) -> float:
280281

281282

282283
def _parse_retry_after(exc: openai.RateLimitError) -> Optional[float]:
283-
"""Extract the Retry-After value (in seconds) from a RateLimitError.
284+
"""
285+
Extract the Retry-After value (in seconds) from a RateLimitError.
284286
285287
Returns ``None`` when the header is missing or cannot be parsed.
286288
"""

llama-index-integrations/llms/llama-index-llms-openai/tests/test_retry_after.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,9 @@ def test_parse_retry_after_missing_header():
6666

6767

6868
def test_parse_retry_after_non_numeric():
69-
exc = _make_rate_limit_error(headers={"Retry-After": "Wed, 21 Oct 2025 07:28:00 GMT"})
69+
exc = _make_rate_limit_error(
70+
headers={"Retry-After": "Wed, 21 Oct 2025 07:28:00 GMT"}
71+
)
7072
assert _parse_retry_after(exc) is None
7173

7274

@@ -126,7 +128,9 @@ def test_wait_retry_after_falls_back_for_non_rate_limit_error():
126128
fallback = MagicMock(return_value=7.0)
127129
strategy = _WaitRetryAfter(fallback)
128130

129-
exc = openai.APITimeoutError(request=httpx.Request("POST", "https://api.openai.com"))
131+
exc = openai.APITimeoutError(
132+
request=httpx.Request("POST", "https://api.openai.com")
133+
)
130134
rs = _make_retry_state(exc)
131135
assert strategy(rs) == 7.0
132136
fallback.assert_called_once_with(rs)

0 commit comments

Comments
 (0)