perf(tradein): снять блокировку event loop на POST /estimate (#2207) #2225

Merged

lekss361 merged 1 commit from fix/tradein-estimate-event-loop into main

2026-07-02 20:39:49 +00:00

lekss361 commented

2026-07-02 20:28:40 +00:00

Owner

Summary

async estimate_quality выпускал ~28 синхронных psycopg PostGIS-запросов прямо на event loop; прод — один uvicorn worker → одна медленная оценка (холодный кэш, wide-radius fallback) стопила все конкурентные запросы, включая /health.
15 sync DB-кластеров обёрнуты в await asyncio.to_thread(...) (паттерн geocoder.py), строго последовательно — Session не используется конкурентно (никакого gather на DB-хелперах).
SAVEPOINT-блок (_backfill_house_fias) целиком внутри одного потока; INSERT + IMV-UPDATE + db.commit() сгруппированы атомарно в один to_thread (побочно улучшает атомарность persist-фазы).
Sync-сигнатуры внутренностей (_price_from_inputs, _fetch_analogs, _fetch_anchor_comps, _fetch_dkp_corridor, _fetch_house_imv_anchor) не тронуты — backtest-harness и frozen CI-регресс-гейт работают как раньше. Pricing-логика не изменена (перенос исполнения, не поведения).
Тест неблокирования: _fetch_analogs → time.sleep(0.3), конкурентная лёгкая корутина завершается за <0.25s (при блокировке было бы ≥0.3).

Как проверено

Полный локальный pytest: 2960 passed, 6 skipped, 1 deselected (включая frozen backtest regression gate + fixture roundtrip).
ruff — чисто. code-reviewer: ✅ APPROVE (diff прочитан построчно, param-словари INSERT сверены 180=180, поведенческих расхождений нет).
Post-deploy план: 3-5 параллельных /estimate изнутри контейнера + /health остаётся отзывчивым.

Refs #2207

## Summary - `async estimate_quality` выпускал ~28 синхронных psycopg PostGIS-запросов прямо на event loop; прод — один uvicorn worker → одна медленная оценка (холодный кэш, wide-radius fallback) стопила все конкурентные запросы, включая `/health`. - 15 sync DB-кластеров обёрнуты в `await asyncio.to_thread(...)` (паттерн geocoder.py), строго последовательно — Session не используется конкурентно (никакого gather на DB-хелперах). - SAVEPOINT-блок (`_backfill_house_fias`) целиком внутри одного потока; INSERT + IMV-UPDATE + `db.commit()` сгруппированы атомарно в один to_thread (побочно улучшает атомарность persist-фазы). - Sync-сигнатуры внутренностей (`_price_from_inputs`, `_fetch_analogs`, `_fetch_anchor_comps`, `_fetch_dkp_corridor`, `_fetch_house_imv_anchor`) не тронуты — backtest-harness и frozen CI-регресс-гейт работают как раньше. Pricing-логика не изменена (перенос исполнения, не поведения). - Тест неблокирования: `_fetch_analogs` → `time.sleep(0.3)`, конкурентная лёгкая корутина завершается за <0.25s (при блокировке было бы ≥0.3). ## Как проверено - Полный локальный pytest: **2960 passed, 6 skipped, 1 deselected** (включая frozen backtest regression gate + fixture roundtrip). - ruff — чисто. code-reviewer: ✅ APPROVE (diff прочитан построчно, param-словари INSERT сверены 180=180, поведенческих расхождений нет). - Post-deploy план: 3-5 параллельных `/estimate` изнутри контейнера + `/health` остаётся отзывчивым. Refs #2207

Rows
Columns