From 165dda599f02ccbc8cb24e28ae2a91f84ae7e476 Mon Sep 17 00:00:00 2001
From: bot-backend <bot-backend@gendsgn.local>
Date: Thu, 13 Aug 2026 12:26:44 +0000
Subject: [PATCH] =?UTF-8?q?docs(ptica):=20=D0=BA=D0=BE=D0=BC=D0=BC=D0=B5?=
 =?UTF-8?q?=D0=BD=D1=82=D0=B0=D1=80=D0=B8=D0=B8=20beat-=D1=80=D0=B0=D1=81?=
 =?UTF-8?q?=D0=BF=D0=B8=D1=81=D0=B0=D0=BD=D0=B8=D1=8F=20=D1=81=D1=87=D0=B8?=
 =?UTF-8?q?=D1=82=D0=B0=D0=BB=D0=B8=20=D1=81=D0=B4=D0=B2=D0=B8=D0=B3=20?=
 =?UTF-8?q?=D0=9C=D0=A1=D0=9A=20=D0=B4=D0=B2=D0=B0=D0=B6=D0=B4=D1=8B=20(#2?=
 =?UTF-8?q?464-H)=20(#2866)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 backend/app/workers/beat_schedule.py | 22 +++++++++++++++-------
 1 file changed, 15 insertions(+), 7 deletions(-)

diff --git a/backend/app/workers/beat_schedule.py b/backend/app/workers/beat_schedule.py
index ff2d812b..5c9eaa82 100644
--- a/backend/app/workers/beat_schedule.py
+++ b/backend/app/workers/beat_schedule.py
@@ -406,16 +406,17 @@ def build_beat_schedule() -> dict:
 
     # Catalog-object scrape — наполняет ~25 NULL колонок domrf_kn_objects из SSR-страниц.
     # kn-API не отдаёт wall_type, energy_eff, ceiling_height_m, parking_* и т.д.
-    # Вторник 04:00 UTC. batch 300/run → 1532 объекта за ~5 недель полного обновления.
+    # Вторник 04:00 МСК (crontab в МСК, #1233). batch 300/run → 1532 объекта
+    # за ~5 недель полного обновления.
     #
     # DISABLED 2026-05-24: DOM.РФ WAF дал hard-ban на VPS IP после серии failed
     # extras-сессий (run 26/27/28). Catalog SSR использует тот же BrowserSession
-    # + те же /сервисы/* paths → следующий beat-tick (вт 26.05 04:00 UTC) насыпет
+    # + те же /сервисы/* paths → следующий beat-tick (вт 26.05 04:00 МСК) насыпет
     # 300 failed SSR fetches и углубит WAF reputation penalty. Возврат после
     # cooldown 24-48h (проверить через targeted test).
     # schedule["scrape-kn-catalog-objects-weekly"] = {
     #     "task": "tasks.scrape_kn_catalog_objects.scrape_kn_catalog_objects",
-    #     "schedule": _parse_cron("0 4 * * 2"),  # Tuesday 04:00 UTC
+    #     "schedule": _parse_cron("0 4 * * 2"),  # вторник 04:00 МСК
     #     "kwargs": {"region_code": 66, "max_objects": 300},
     #     "options": {"queue": "celery"},
     # }
@@ -430,10 +431,10 @@ def build_beat_schedule() -> dict:
     # свежий kn-sweep не наполнил hash, SELECT вернёт 0 строк — включать смысла нет.
     # Возврат после WAF-cooldown + первого kn-sweep с hash (проверить targeted-тестом).
     # Разнести по времени с object-scrape (вт 04:00), чтобы не двоить WAF-нагрузку —
-    # напр. четверг 04:00 UTC.
+    # напр. четверг 04:00 МСК.
     # schedule["scrape-kn-catalog-flats-weekly"] = {
     #     "task": "tasks.scrape_kn_catalog_flats.scrape_kn_catalog_flats",
-    #     "schedule": _parse_cron("0 4 * * 4"),  # Thursday 04:00 UTC
+    #     "schedule": _parse_cron("0 4 * * 4"),  # четверг 04:00 МСК
     #     "kwargs": {"region_code": 66, "max_flats": 300},
     #     "options": {"queue": "celery"},
     # }
@@ -542,13 +543,20 @@ def build_beat_schedule() -> dict:
     }
 
     # Cross-load ETL tradein→gendesign (#976 950-E5): tradein.houses → newbuilding_listings.
-    # Ночной запуск: 00:30 UTC = 03:30 МСК (Celery conf.timezone=Europe/Moscow → crontab в МСК).
+    # 00:30 МСК ежедневно (Celery conf.timezone=Europe/Moscow → crontab в МСК, #1233).
+    # Комментарий до #2464-H говорил «00:30 UTC = 03:30 МСК» — считал сдвиг дважды,
+    # оставшись с эпохи UTC-расписания. Факт по логам beat (10-12.08): «Sending due
+    # task newbuilding-crossload-nightly» в 21:30 UTC = 00:30 МСК, то есть на три
+    # часа раньше обещанного.
+    # Расписание НЕ трогаем: на 00:30 МСК ничего не наложено, а сдвиг на 03:30 МСК
+    # завёл бы задачу прямо в окно tradein-задания newbuilding_enrich (00:00-01:00 UTC
+    # = 03:00-04:00 МСК), с которым она делит источник — tradein.houses.
     # Не в job_settings (технический ETL, не требует конфигурации UI).
     # Идемпотентен через ON CONFLICT (source, ext_house_id).
     # Если TRADEIN_DATABASE_URL не задан → warn-log, {"disabled": True} без исключения.
     schedule["newbuilding-crossload-nightly"] = {
         "task": "tasks.etl_newbuilding_crossload.etl_newbuilding_crossload",
-        "schedule": _parse_cron("30 0 * * *"),  # 00:30 UTC = 03:30 МСК
+        "schedule": _parse_cron("30 0 * * *"),  # 00:30 МСК
         "options": {"queue": "celery"},
     }