tradein-mvp/backend/app/services/estimator.py

@@ -906,18 +906,8 @@ def _defer_external_refresh(label: str, work: Callable[[Session], Awaitable[obje
         db = SessionLocal()
         try:
             await work(db)
-        except Exception as exc:
+        except Exception:
-            if caused_by_no_proxy(exc):
+            logger.exception("deferred %s: догрузка не удалась (кэш не прогрет)", label)
-                # #3398: пустой пул — НАША инфраструктура, HTTP-запрос не уходил вовсе
-                # (NoProxyAvailableError поднимается в curl_proxy_url ДО запроса). WARNING,
-                # не ERROR: GlitchTip слушает event_level=ERROR, а это штатная деградация
-                # прогрева, не сбой площадки — событие тут было бы шумом.
-                # На проде ESTIMATE_EXTERNAL_SOURCES_BACKGROUND=true, поэтому настоящий
-                # фетч уходит именно сюда: synchronous-ветка с fetch_on_miss=False отдаёт
-                # None ДО прокси-слоя и до своего WARNING в estimate_quality не доходит.
-                logger.warning("deferred %s: пул прокси пуст — кэш не прогрет: %s", label, exc)
-            else:
-                logger.exception("deferred %s: догрузка не удалась (кэш не прогрет)", label)
         finally:
             db.close()
 
@@ -1016,27 +1006,14 @@ async def _get_or_fetch_yandex_valuation_cached(
     # Fresh fetch
     try:
         async with YandexValuationScraper(
-            RealScraperConfig(),
+            RealScraperConfig(), delay_provider=get_scraper_delay
-            delay_provider=get_scraper_delay,
-            # #3398: без provider'а `curl_proxy_url` считает use_pool=False (флаг AND
-            # provider is not None) — пул выключен по построению, curl-сессия уходит на
-            # env-прокси SCRAPER_PROXY_URL (мёртвый узел #2613 → 407 на каждой пробе).
-            # Lease один на сессию: acquire в __aenter__, release в __aexit__ — в т.ч.
-            # на исключении и на отмене по таймауту _with_budget.
-            proxy_provider=RealProxyProvider(),
         ) as scraper:
             result = await scraper.fetch_house_history(
                 address=address,
                 offer_category=offer_category,
                 offer_type=offer_type,
             )
-    except Exception as e:
+    except Exception:
-        if caused_by_no_proxy(e):
-            # #3398: «пул прокси пуст» — НАША инфраструктура, HTTP-запрос не уходил вовсе.
-            # Отдельный текст (и WARNING, не ERROR): это не сбой Яндекса, GlitchTip-событие
-            # здесь было бы шумом. Возврат None — тот же graceful путь, /estimate не 5xx.
-            logger.warning("yandex_valuation: пул прокси пуст — продолжаем без Yandex: %s", e)
-            return None
         # logger.exception (не .warning) — намеренно: GlitchTip LoggingIntegration
         # (main.py/scheduler_main.py) слушает event_level=logging.ERROR. WARNING,
         # даже с exc_info=True, остаётся ниже порога и НЕ создаёт событие в GlitchTip
@@ -1046,15 +1023,7 @@ async def _get_or_fetch_yandex_valuation_cached(
         return None
 
     if result is None:
-        # #3398: None здесь НЕразличимо «дом не найден» и «фетч не дошёл» — kit ловит
+        logger.info("yandex_valuation: empty result for address=%s", address[:60])
-        # ProxyError/HTTP-код внутри fetch_house_history и логирует своей строкой
-        # («yandex valuation fetch failed» / «returned NNN»). Прежний текст «empty result»
-        # читался как «у Яндекса нет данных», хотя при мёртвом прокси это был 407.
-        logger.info(
-            "yandex_valuation: пусто для address=%s — данных нет ЛИБО фетч не дошёл "
-            "(причина строкой выше от scraper_kit: прокси/HTTP)",
-            address[:60],
-        )
         return None
 
     # Save to cache (UPSERT on (source, cache_key))
@@ -4655,21 +4624,6 @@ async def estimate_quality(
             "deal_type": "sale",
             "use_cache": True,
             "house_id": target_house_id,
-            # #3398: без provider'а curl_proxy_url считает use_pool=False (флаг AND
-            # provider is not None) → env-прокси CIAN_PROXY_URL/SCRAPER_PROXY_URL, мёртвый
-            # узел (#2613) → «Cian valuation fetch failed: … 407». Lease живёт внутри
-            # curl_proxy_url: acquire до запроса, release в finally.
-            #
-            # Весь этот dict переиспользуется отложенной фоновой догрузкой ниже
-            # (`_defer_external_refresh` захватывает `_c_kwargs` замыканием), то есть
-            # `config` и `proxy_provider` — ОДИН инстанс на два вызова, которые могут идти
-            # одновременно (фон стартует после ответа, но живёт своей задачей). Корректно
-            # это ровно пока оба stateless: `RealScraperConfig` — read-only снимок настроек,
-            # `RealProxyProvider` не хранит полей вообще и открывает короткую сессию БД на
-            # каждую операцию (acquire/release/mark_health), поэтому lease'ы двух вызовов не
-            # пересекаются. Появится у любого из них per-вызов состояние (кэш lease'а,
-            # счётчик, открытая сессия) — фоновой задаче нужен СВОЙ инстанс, а не общий.
-            "proxy_provider": RealProxyProvider(),
         }
         try:
             cian_val = await _with_budget(
@@ -4689,19 +4643,13 @@ async def estimate_quality(
                     cian_val.sale_accuracy,
                     cian_val.external_house_id,
                 )
-        except Exception as e:
+        except Exception:
-            if caused_by_no_proxy(e):
+            # logger.exception (не .warning) — намеренно: GlitchTip LoggingIntegration
-                # #3398: пустой пул поднимает NoProxyAvailableError ДО HTTP (curl_proxy_url),
+            # (main.py/scheduler_main.py) слушает event_level=logging.ERROR. WARNING,
-                # то есть это не сбой Циана. WARNING, не ERROR: в GlitchTip такое событие —
+            # даже с exc_info=True, остаётся ниже порога и НЕ создаёт событие в GlitchTip
-                # шум. Оценка отдаётся без cian-источника, /estimate не 5xx.
+            # (только breadcrumb) — config-wiring регрессия здесь была бы не видна
-                logger.warning("cian_valuation: пул прокси пуст — продолжаем без Cian: %s", e)
+            # мониторингу. .exception() логирует на ERROR + traceback (#2337).
-            else:
+            logger.exception("cian_valuation: lookup failed (graceful)")
-                # logger.exception (не .warning) — намеренно: GlitchTip LoggingIntegration
-                # (main.py/scheduler_main.py) слушает event_level=logging.ERROR. WARNING,
-                # даже с exc_info=True, остаётся ниже порога и НЕ создаёт событие в GlitchTip
-                # (только breadcrumb) — config-wiring регрессия здесь была бы не видна
-                # мониторингу. .exception() логирует на ERROR + traceback (#2337).
-                logger.exception("cian_valuation: lookup failed (graceful)")
 
     # ── Pre-fetch: same-building anchor comps ─────────────────────────────────
     # Guard mirrors the original in-block guard exactly; when false → ([], None).

tradein-mvp/backend/tests/test_3398_estimator_valuations_proxy_pool.py

@@ -1,390 +0,0 @@
-"""Yandex/Cian valuation в /estimate идут через пул прокси, пустой пул не роняет ответ (#3398).
-
-Корень тот же, что у IMV (#3386/PR #3397): `estimator` звал kit БЕЗ `proxy_provider` —
-`YandexValuationScraper(RealScraperConfig(), delay_provider=...)` и
-`estimate_via_cian_valuation(**_c_kwargs)`. `providers/_proxy.py::curl_proxy_url` считает
-`use_pool = флаг AND proxy_provider is not None`, поэтому пул был выключен ПО ПОСТРОЕНИЮ, а
-curl уходил на env-прокси `SCRAPER_PROXY_URL` (выключенный узел, #2613) → на проде каждая
-проба `/estimate` давала `407 CONNECT tunnel failed` и «yandex_valuation: empty result».
-
-Проверки по значению:
-  (а) оба call site передают provider'а (на main здесь None);
-  (б) пул пуст + environment=production → оценка отдаётся БЕЗ этих источников, без
-      исключения, HTTP не уходит, а причина в логе честная — «пул прокси пуст»;
-  (б2) прод-режим `ESTIMATE_EXTERNAL_SOURCES_BACKGROUND=true`: синхронный вызов уходит
-      с `fetch_on_miss=False` и до прокси-слоя не доходит вовсе, настоящий фетч делает
-      `_defer_external_refresh` — там пустой пул тоже WARNING, а не ERROR с трейсбеком
-      (иначе GlitchTip получает событие на каждый /estimate по новому адресу);
-  (в) lease освобождён ровно один раз (успех и ошибка фетча) — через настоящий
-      `curl_proxy_url`, а не через мок провайдера.
-"""
-
-from __future__ import annotations
-
-import asyncio
-import logging
-import os
-from contextlib import ExitStack
-from datetime import UTC, datetime
-from typing import Any
-from unittest.mock import AsyncMock, MagicMock, patch
-
-os.environ.setdefault("DATABASE_URL", "postgresql+psycopg://test:test@localhost:5432/test")
-
-import anyio
-import pytest
-from scraper_kit.contracts import ProxyLease
-
-from app.core.config import settings
-from app.schemas.trade_in import TradeInEstimateInput
-from app.services import estimator
-from app.services.estimator import _get_or_fetch_yandex_valuation_cached, estimate_quality
-from app.services.geocoder import GeocodeResult
-
-_ADDRESS = "Первоуральск, ул. Ленина, 5"
-
-
-# ── провайдеры-дублёры ──────────────────────────────────────────────────────
-
-
-class _EmptyPoolProvider:
-    """acquire → None (все узлы забанены/заняты)."""
-
-    def acquire(self, provider: str) -> ProxyLease | None:
-        return None
-
-    def release(self, lease: ProxyLease) -> None:  # pragma: no cover — не должно звучать
-        raise AssertionError("release без lease")
-
-    def mark_health(self, lease: ProxyLease, ok: bool, **kw: Any) -> None:  # pragma: no cover
-        raise AssertionError("mark_health без lease")
-
-    def mark_banned(self, lease: ProxyLease, *, source: str) -> None:  # pragma: no cover
-        raise AssertionError("mark_banned без lease")
-
-
-class _CountingProvider:
-    def __init__(self) -> None:
-        self.acquired: list[str] = []
-        self.released: list[int] = []
-        self.health: list[bool] = []
-
-    def acquire(self, provider: str) -> ProxyLease | None:
-        self.acquired.append(provider)
-        return ProxyLease(id=7, url="http://pool-node:3128", kind="datacenter", rotate_url=None)
-
-    def release(self, lease: ProxyLease) -> None:
-        self.released.append(lease.id)
-
-    def mark_health(self, lease: ProxyLease, ok: bool, **kw: Any) -> None:
-        self.health.append(ok)
-
-    def mark_banned(self, lease: ProxyLease, *, source: str) -> None:
-        pass
-
-
-def _no_http(*a: Any, **kw: Any) -> Any:  # pragma: no cover — не должно вызваться
-    raise AssertionError("HTTP-запрос при пустом пуле — прокси-гейт не сработал")
-
-
-class _FakeResponse:
-    def __init__(self, status_code: int, text: str) -> None:
-        self.status_code = status_code
-        self.text = text
-
-
-def _fake_curl_session(*, get: Any) -> Any:
-    """Заглушка curl_cffi.AsyncSession: и как async-CM (cian), и как объект (yandex)."""
-    session = MagicMock()
-    session.get = get
-    session.close = AsyncMock()
-    session.__aenter__ = AsyncMock(return_value=session)
-    session.__aexit__ = AsyncMock(return_value=False)
-    return lambda *a, **kw: session
-
-
-def _use_pool_in_production(monkeypatch: pytest.MonkeyPatch) -> None:
-    monkeypatch.setattr(settings, "use_proxy_pool_curl", True)
-    monkeypatch.setattr(settings, "environment", "production")
-    # fetch_on_miss=False (фоновый режим) вернул бы None ДО прокси-слоя — тест
-    # проверял бы тогда пустоту кэша, а не проводку пула.
-    monkeypatch.setattr(settings, "estimate_external_sources_background", False)
-
-
-# ── (а) yandex: провайдер доезжает до скрейпера ──────────────────────────────
-
-
-def _db_cache_miss() -> MagicMock:
-    db = MagicMock()
-    db.execute.return_value.mappings.return_value.first.return_value = None
-    return db
-
-
-def _call_yandex(db: Any) -> Any:
-    async def _run() -> Any:
-        return await _get_or_fetch_yandex_valuation_cached(db, address=_ADDRESS)
-
-    return anyio.run(_run)
-
-
-def test_yandex_valuation_call_passes_proxy_provider() -> None:
-    """YandexValuationScraper получает proxy_provider (на main здесь None → пул off)."""
-    captured: dict[str, Any] = {}
-
-    def _fake_scraper_cls(*args: Any, **kwargs: Any) -> Any:
-        captured.update(kwargs)
-        scraper = MagicMock()
-        scraper.fetch_house_history = AsyncMock(return_value=None)
-        scraper.__aenter__ = AsyncMock(return_value=scraper)
-        scraper.__aexit__ = AsyncMock(return_value=False)
-        return scraper
-
-    with patch.object(estimator, "YandexValuationScraper", _fake_scraper_cls):
-        assert _call_yandex(_db_cache_miss()) is None
-
-    assert captured, "скрейпер не создавался — тест ничего не проверил"
-    assert captured.get("proxy_provider") is not None
-
-
-# ── (а) cian: провайдер доезжает до kit-функции ──────────────────────────────
-
-
-def _geo() -> GeocodeResult:
-    return GeocodeResult(lat=56.909, lon=59.960, full_address=_ADDRESS, provider="nominatim")
-
-
-def _listing(i: int) -> dict[str, Any]:
-    return {
-        "source": "avito",
-        "source_url": f"https://avito.ru/offer/{i}",
-        "address": f"д. {i}",
-        "lat": 56.909,
-        "lon": 59.960,
-        "rooms": 2,
-        "area_m2": 45.0,
-        "floor": 5,
-        "total_floors": 9,
-        "price_rub": (200_000.0 + i * 1_000) * 45.0,
-        "price_per_m2": 200_000.0 + i * 1_000,
-        "listing_date": datetime(2026, 5, 1, tzinfo=UTC),
-        "days_on_market": 10,
-        "photo_urls": [],
-        "scraped_at": datetime(2026, 5, 20, tzinfo=UTC),
-        "distance_m": 150.0,
-        "relevance_score": 0.1,
-    }
-
-
-def _run_estimate(*, extra_patches: list[Any], drain_deferred: bool = False) -> Any:
-    """estimate_quality() со всеми внешними источниками кроме Cian заглушенными.
-
-    Cian намеренно НЕ патчится списком по умолчанию: тесты (б)/(в) гоняют настоящую
-    kit-функцию, чтобы прокси-слой (`curl_proxy_url`) реально отработал.
-
-    drain_deferred: дождаться задач фоновой догрузки (`_DEFERRED_REFRESH_TASKS`) ВНУТРИ
-    того же loop'а и не снимая патчей. Без ожидания `anyio.run` закрывает loop сразу
-    после ответа, задача умирает не начавшись («Task was destroyed but it is pending»)
-    и тест по фоновому пути был бы зелёным по построению.
-    """
-    payload = TradeInEstimateInput(address=_ADDRESS, area_m2=45.0, rooms=2, floor=5, total_floors=9)
-
-    patches = [
-        patch("app.services.estimator.geocode", new=AsyncMock(return_value=_geo())),
-        patch("app.services.estimator.dadata_clean_address", new=AsyncMock(return_value=None)),
-        patch("app.services.estimator.match_house_readonly", return_value=None),
-        patch("app.services.estimator.get_house_metadata", new=AsyncMock(return_value=None)),
-        patch(
-            "app.services.estimator._fetch_analogs",
-            return_value=([_listing(i) for i in range(8)], False, "W"),
-        ),
-        patch("app.services.estimator._fetch_anchor_comps", return_value=([], None)),
-        patch("app.services.estimator._fetch_deals", return_value=[]),
-        patch("app.services.estimator._get_or_fetch_imv_cached", new=AsyncMock(return_value=None)),
-        patch(
-            "app.services.estimator._get_or_fetch_yandex_valuation_cached",
-            new=AsyncMock(return_value=None),
-        ),
-        patch("app.services.estimator._fetch_dkp_corridor", return_value=None),
-        patch("app.services.estimator._get_asking_sold_ratio", return_value=(None, None)),
-        *extra_patches,
-    ]
-
-    async def _run() -> Any:
-        with ExitStack() as stack:  # список патчей переменной длины — не `with (...)`
-            for p in patches:
-                stack.enter_context(p)
-            est = await estimate_quality(payload, MagicMock())
-            if drain_deferred:
-                # gather с return_exceptions=False: задача сама гасит свои ошибки, а если
-                # перестанет — тест обязан покраснеть, а не проглотить.
-                await asyncio.gather(*list(estimator._DEFERRED_REFRESH_TASKS))
-            return est
-
-    return anyio.run(_run)
-
-
-def test_cian_valuation_call_passes_proxy_provider(monkeypatch: pytest.MonkeyPatch) -> None:
-    """estimate_via_cian_valuation получает proxy_provider (на main здесь None)."""
-    _use_pool_in_production(monkeypatch)
-    captured: dict[str, Any] = {}
-
-    async def _fake_cian(_db: Any, **kwargs: Any) -> None:
-        captured.update(kwargs)
-        return None
-
-    est = _run_estimate(
-        extra_patches=[patch("app.services.estimator.estimate_via_cian_valuation", new=_fake_cian)]
-    )
-    assert est is not None
-    assert captured, "cian-вызов не состоялся — тест ничего не проверил"
-    assert captured.get("proxy_provider") is not None
-
-
-# ── (б) пустой пул в проде: деградация, а не 5xx ─────────────────────────────
-
-
-def test_yandex_empty_pool_in_production_degrades(
-    monkeypatch: pytest.MonkeyPatch, caplog: pytest.LogCaptureFixture
-) -> None:
-    """Пул пуст → None (ответ без Yandex), HTTP не уходит, причина в логе честная."""
-    _use_pool_in_production(monkeypatch)
-    result: Any = "unset"
-
-    with (
-        # Без create=True: RealProxyProvider импортирован в estimator — патч обязан
-        # бить по РЕАЛЬНОМУ атрибуту, иначе переименование импорта оставит тест зелёным.
-        patch.object(estimator, "RealProxyProvider", _EmptyPoolProvider),
-        patch("scraper_kit.providers.yandex.valuation._CurlCffiSession", _no_http),
-        caplog.at_level(logging.WARNING, logger="app.services.estimator"),
-    ):
-        result = _call_yandex(_db_cache_miss())
-
-    assert result is None
-    assert "пул прокси пуст" in caplog.text, caplog.text
-    assert "fetch failed" not in caplog.text, "причина подменена на неспецифичную"
-
-
-def test_cian_empty_pool_in_production_degrades(
-    monkeypatch: pytest.MonkeyPatch, caplog: pytest.LogCaptureFixture
-) -> None:
-    """Тот же контракт для Cian: оценка возвращается, исключение не всплывает наружу."""
-    _use_pool_in_production(monkeypatch)
-
-    with (
-        patch.object(estimator, "RealProxyProvider", _EmptyPoolProvider),
-        patch("scraper_kit.providers.cian.valuation._load_from_cache", return_value=None),
-        patch(
-            "scraper_kit.providers.cian.valuation.load_session",
-            return_value={"cookie": "x"},
-        ),
-        patch("scraper_kit.providers.cian.valuation.AsyncSession", _no_http),
-        caplog.at_level(logging.WARNING, logger="app.services.estimator"),
-    ):
-        est = _run_estimate(extra_patches=[])
-
-    assert est is not None  # /estimate отвечает, просто без cian-источника
-    assert "пул прокси пуст" in caplog.text, caplog.text
-    assert "lookup failed" not in caplog.text, "причина подменена на неспецифичную"
-
-
-# ── (б2) фоновый режим (прод-конфиг): пустой пул — WARNING, не ERROR ─────────
-
-
-def test_cian_deferred_refresh_empty_pool_warns_without_traceback(
-    monkeypatch: pytest.MonkeyPatch, caplog: pytest.LogCaptureFixture
-) -> None:
-    """Прод-путь: ESTIMATE_EXTERNAL_SOURCES_BACKGROUND=true → фетч уходит в фон.
-
-    На проде (`docker-compose.prod.yml`) флаг включён, поэтому синхронный вызов идёт с
-    `fetch_on_miss=False` и возвращает None ДО прокси-слоя (`providers/cian/valuation.py`
-    «cache MISS — fetch отложен») — ветка WARNING в `estimate_quality` там не звучит.
-    Настоящий фетч делает `_defer_external_refresh`, где `NoProxyAvailableError` попадал в
-    общий `except Exception: logger.exception(...)` → ERROR + traceback → событие в
-    GlitchTip: ровно тот шум, который #3398 и убирает.
-    """
-    _use_pool_in_production(monkeypatch)
-    monkeypatch.setattr(settings, "estimate_external_sources_background", True)
-    estimator._DEFERRED_REFRESH_TASKS.clear()  # чужие мёртвые задачи из прошлых loop'ов
-
-    with (
-        patch.object(estimator, "RealProxyProvider", _EmptyPoolProvider),
-        # Фоновая задача открывает СВОЮ сессию (сессия запроса закрыта вместе с ответом) —
-        # в тесте она не должна ходить в реальную БД.
-        patch.object(estimator, "SessionLocal", MagicMock(return_value=MagicMock())),
-        patch("scraper_kit.providers.cian.valuation._load_from_cache", return_value=None),
-        patch("scraper_kit.providers.cian.valuation.load_session", return_value={"cookie": "x"}),
-        patch("scraper_kit.providers.cian.valuation.AsyncSession", _no_http),
-        caplog.at_level(logging.INFO, logger="app.services.estimator"),
-    ):
-        est = _run_estimate(extra_patches=[], drain_deferred=True)
-
-    assert est is not None
-    ours = [r for r in caplog.records if r.name == "app.services.estimator"]
-    deferred = [r for r in ours if "deferred cian_valuation" in r.getMessage()]
-    assert deferred, [r.getMessage() for r in ours]  # фоновая задача не отработала
-    assert all("пул прокси пуст" in r.getMessage() for r in deferred), [
-        r.getMessage() for r in deferred
-    ]
-    errors = [r for r in ours if r.levelno >= logging.ERROR]
-    assert not errors, [(r.levelname, r.getMessage()) for r in errors]
-    assert not any(r.exc_info for r in ours), "traceback приложен — GlitchTip получит событие"
-    assert "Traceback" not in caplog.text, caplog.text
-
-
-# ── (в) lease освобождён ровно один раз, через настоящий curl_proxy_url ──────
-
-
-def _yandex_with_pool(monkeypatch: pytest.MonkeyPatch, *, get: Any) -> _CountingProvider:
-    _use_pool_in_production(monkeypatch)
-    provider = _CountingProvider()
-    with (
-        patch.object(estimator, "RealProxyProvider", lambda: provider),
-        patch(
-            "scraper_kit.providers.yandex.valuation._CurlCffiSession", _fake_curl_session(get=get)
-        ),
-    ):
-        _call_yandex(_db_cache_miss())
-    return provider
-
-
-def test_yandex_lease_released_once_on_success(monkeypatch: pytest.MonkeyPatch) -> None:
-    provider = _yandex_with_pool(
-        monkeypatch, get=AsyncMock(return_value=_FakeResponse(200, "<html></html>"))
-    )
-    assert provider.acquired == ["yandex"]
-    assert provider.released == [7]
-    assert provider.health == [True]
-
-
-def test_yandex_lease_released_once_on_fetch_error(monkeypatch: pytest.MonkeyPatch) -> None:
-    """Ошибка транспорта (на проде — 407 от мёртвого env-прокси) не течёт lease'ом."""
-    provider = _yandex_with_pool(monkeypatch, get=AsyncMock(side_effect=OSError("proxy 407")))
-    assert provider.acquired == ["yandex"]
-    assert provider.released == [7]
-
-
-def test_cian_lease_released_once_on_fetch_error(monkeypatch: pytest.MonkeyPatch) -> None:
-    _use_pool_in_production(monkeypatch)
-    provider = _CountingProvider()
-
-    with (
-        patch.object(estimator, "RealProxyProvider", lambda: provider),
-        patch("scraper_kit.providers.cian.valuation._load_from_cache", return_value=None),
-        patch(
-            "scraper_kit.providers.cian.valuation.load_session",
-            return_value={"cookie": "x"},
-        ),
-        patch(
-            "scraper_kit.providers.cian.valuation.AsyncSession",
-            _fake_curl_session(get=AsyncMock(side_effect=OSError("proxy 407"))),
-        ),
-    ):
-        est = _run_estimate(extra_patches=[])
-
-    assert est is not None
-    assert provider.acquired == ["cian"]
-    assert provider.released == [7]
-
-
-if __name__ == "__main__":  # pragma: no cover
-    raise SystemExit(pytest.main([__file__, "-q"]))