fix(llm): cap серверного Retry-After через _MAX_BACKOFF_S=30s (#1209) #1261
No reviewers
Labels
No labels
admin
analytics
auth
automation
bug
business
chore
ci
compliance
data
data-moat
docs
duplicate
dx
enhancement
Fable 5 ревью
feedback/max
generative
GG-форсайт
needs-discussion
needs-human
observability
pause-bots
performance
priority/p0
priority/p1
priority/p2
priority/p3
scope/backend
scope/db
scope/devops
scope/frontend
scope/qa
scrapers
security
site-finder
stage/1
stage/2
status/blocked
status/done
status/needs-analysis
status/needs-fix
status/qa
status/ready
status/review
status/wip
tech-debt
tradein
ux
week ревью 1
wontfix
вторичка
ИРД
No milestone
No project
No assignees
1 participant
Notifications
Due date
No due date set.
Dependencies
No dependencies set.
Reference: lekss361/gendesign#1261
Loading…
Add table
Reference in a new issue
No description provided.
Delete branch "fix/llm-client-retry-after-cap"
Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?
Summary
Closes #1209 (P2 performance / availability). Серверный
Retry-Afterне капался →time.sleepмог блокироватьanyio-threadpoolна часы → исчерпание пула → стопор приложения.Bug
client.py:215:Cap
min(...,30)применён ТОЛЬКО к exponential backoff. СерверныйRetry-Afterуходит как есть. Provider'ы шлют до 86400с при quota-exhaustion (OpenAI, CDN-503).Эффект:
time.sleepблокирует потокanyio-threadpoolна часы (до 48ч приllm_max_retries=2). Chat-консьюмер (chat.py) мостится черезrun_in_threadpool— поток держит токен пула (~40, общий сsync Depends(get_db)) и DB-сессию → пул исчерпывается → стопор приложения.Fix
_MAX_BACKOFF_S = 30.0.raw_waitлогируется отдельно (наблюдаемость — видно когда провайдер просил больше).Test plan
test_rate_limited_retry_after_capped: provider шлётretry_after=86400→time.sleepвызывается с 30, не 86400.pytest tests/services/llm/test_client.py→ 14 passed.pytest tests/services/llm/→ 55 passed.ruff check→ clean.Closes #1209
В complete-loop'е min(...,30) применялся ТОЛЬКО к exponential backoff'у (else-ветка). Серверный Retry-After уходил в time.sleep как есть. _parse_retry_after принимает любое число секунд ("86400".isdigit() → True), а provider'ы шлют Retry-After до 86400с при quota-exhaustion (OpenAI, CDN-503). Эффект: time.sleep блокирует поток anyio-threadpool на часы (до 48ч при llm_max_retries=2). Async-консьюмер (chat.py) мостится через run_in_threadpool — поток держит токен пула (~40 потоков, общий с sync Depends(get_db)) и DB-сессию → пул исчерпывается → стопор приложения. Patch: вынес кап на module-level _MAX_BACKOFF_S=30s, применяю к ОБЕИМ веткам (Retry-After И exp.backoff). raw_wait логируется отдельно для наблюдаемости (видно когда провайдер просил больше). Новый юнит-тест test_rate_limited_retry_after_capped: provider шлёт retry_after=86400 → time.sleep вызывается с 30 (не 86400). 14/14 client тестов + 55/55 LLM-suite зелёные. ruff clean. Closes #1209