From e77bc9fe0666d5b41d7d0ef893d0e54c0d50a863 Mon Sep 17 00:00:00 2001
From: lekss361 <alexey.kondratev@balance-pl.ru>
Date: Sun, 24 May 2026 17:44:20 +0300
Subject: [PATCH] fix(tradein/cian): rename counter to price_changes_attempted
 + cap batch_size <=200

---
 tradein-mvp/backend/app/api/v1/admin.py                | 4 ++--
 tradein-mvp/backend/app/tasks/cian_history_backfill.py | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/tradein-mvp/backend/app/api/v1/admin.py b/tradein-mvp/backend/app/api/v1/admin.py
index 3acca303..695aabbf 100644
--- a/tradein-mvp/backend/app/api/v1/admin.py
+++ b/tradein-mvp/backend/app/api/v1/admin.py
@@ -1029,7 +1029,7 @@ class CianBackfillResp(BaseModel):
     listings_succeeded: int
     listings_failed_fetch: int
     listings_failed_save: int
-    price_changes_inserted: int
+    price_changes_attempted: int
     houses_total: int
     houses_processed: int
     houses_succeeded: int
@@ -1040,7 +1040,7 @@ class CianBackfillResp(BaseModel):
 
 @router.post("/scrape/cian-backfill-history", response_model=CianBackfillResp)
 async def scrape_cian_backfill_history(
-    batch_size: int = 50,
+    batch_size: int = Query(50, ge=1, le=200),
     do_listings: bool = True,
     do_houses: bool = True,
     dry_run: bool = False,
diff --git a/tradein-mvp/backend/app/tasks/cian_history_backfill.py b/tradein-mvp/backend/app/tasks/cian_history_backfill.py
index 84cf847a..af81a736 100644
--- a/tradein-mvp/backend/app/tasks/cian_history_backfill.py
+++ b/tradein-mvp/backend/app/tasks/cian_history_backfill.py
@@ -40,7 +40,7 @@ class CianBackfillResult:
     listings_succeeded: int = 0
     listings_failed_fetch: int = 0
     listings_failed_save: int = 0
-    price_changes_inserted: int = 0
+    price_changes_attempted: int = 0
     houses_total: int = 0
     houses_processed: int = 0
     houses_succeeded: int = 0
@@ -130,7 +130,7 @@ async def backfill_cian_history(
                 try:
                     save_detail_enrichment(db, listing_id, enrichment)
                     result.listings_succeeded += 1
-                    result.price_changes_inserted += len(enrichment.price_changes or [])
+                    result.price_changes_attempted += len(enrichment.price_changes or [])
                 except Exception as exc:
                     logger.warning(
                         "cian_detail save failed for listing_id=%s: %s", listing_id, exc
@@ -161,7 +161,7 @@ async def backfill_cian_history(
         result.listings_succeeded,
         result.listings_failed_fetch,
         result.listings_failed_save,
-        result.price_changes_inserted,
+        result.price_changes_attempted,
         result.houses_processed,
         result.houses_total,
         result.houses_succeeded,