tradein-mvp/backend/app/tasks/avito_detail_backfill.py

@@ -29,14 +29,6 @@ from scraper_kit.avito_exceptions import (
     AvitoRateLimitedError,
 )
 from scraper_kit.browser_fetcher import BrowserFetcher
-
-# #2397 slice B (эпик #2277 decommission scrape_pipeline.py, Part E): раньше
-# _CHROME_HEADERS/_avito_proxies() импортировались из app.services.scrape_pipeline.
-# kit уже вынес byte-идентичный dict (DOCUMENT_HEADERS) и ту же формулу
-# {"http": url, "https": url} if url else None (http_proxies) в
-# providers/_base.py (#2358 Foundation) — реюзаем вместо копии, разрывая
-# зависимость от scrape_pipeline.py перед его удалением.
-from scraper_kit.providers._base import DOCUMENT_HEADERS, http_proxies
 from scraper_kit.providers.avito.detail import (
     fetch_detail,
     research_in_session,
@@ -49,6 +41,7 @@ from sqlalchemy.orm import Session
 from app.core.config import settings
 from app.core.shutdown import shutdown_requested
 from app.services import scrape_runs as runs_mod
+from app.services.scrape_pipeline import _CHROME_HEADERS, _avito_proxies
 from app.services.scraper_adapters import RealScraperConfig
 
 # _AVITO_WARM_SEARCH_URL/build_warmed_session остаются legacy (#2310): kit's
@@ -181,8 +174,8 @@ async def run_avito_detail_backfill(
             session = AsyncSession(
                 impersonate="chrome120",
                 timeout=25,
-                headers=DOCUMENT_HEADERS,
-                proxies=http_proxies(settings.scraper_proxy_url),
+                headers=_CHROME_HEADERS,
+                proxies=_avito_proxies(),
             )
             scraper._cffi = session