backend/app/workers/beat_schedule.py

@@ -50,21 +50,22 @@ def _default_regions() -> list[int]:
     return [int(x.strip()) for x in settings.scrape_kn_default_regions.split(",") if x.strip()]
 
 
-def _build_beat_schedule_from_db() -> tuple[dict, int]:
+def _build_beat_schedule_from_db() -> dict:
     """Строит beat_schedule из job_settings БД.
 
-    Returns: (schedule, rows_seen).
-    - rows_seen > 0  → DB reachable, есть конфигурация job_settings (даже если все disabled)
-    - rows_seen == 0 → DB reachable, но таблица пустая (fresh install до seed'а)
-    - **RAISES** при недоступности БД (table missing, connection refused и т.п.) —
-      caller должен поймать и использовать env-based fallback как safety net.
+    Returns: schedule (может быть пустой если все enabled rows без cron или disabled).
 
-    Используем `get_all` (strict, raises on failure), НЕ `get_all_safe` — нам важно
-    отличить "DB unreachable" от "DB сказал ничего не schedule'ить".
-    Без этого пара UPDATE job_settings SET enabled=false бессильна:
-    `_build_beat_schedule_from_db` вернул бы {} как при DB error → caller fallback'ает
-    на env-cron → отключённые jobs снова в schedule. См. инцидент 2026-05-24
-    (WAF cooldown disable scrape_kn → fallback вернул его обратно).
+    `get_all` маскирует DB-unreachable case через возврат _DEFAULTS (4 synthetic
+    rows, все enabled=True с дефолтными cron'ами) — это значит "DB unreachable" и
+    "fresh install (table empty)" неотличимы от "normal с _DEFAULTS". В обоих
+    случаях schedule НЕ будет пустым — _DEFAULTS дадут scrape_kn + objective_sync.
+
+    КРИТИЧНО для operator-disable scenario: когда DB reachable и оператор сделал
+    `UPDATE job_settings SET enabled=false WHERE job_type IN (...)` — get_all
+    вернёт реальные rows (НЕ _DEFAULTS), loop их пропустит → schedule={}. Caller
+    (build_beat_schedule) НЕ должен срывался на env fallback в этом случае,
+    иначе disable бесполезен. См. инцидент 2026-05-24 (WAF cooldown disable
+    scrape_kn → old code fallback'ал scrape_kn обратно из env).
     """
     from app.core.db import SessionLocal
     from app.services.job_settings import get_all
@@ -128,7 +129,7 @@ def _build_beat_schedule_from_db() -> tuple[dict, int]:
             }
             logger.info("build_beat_schedule: %s cron=%r queue=%s", jt, cron_str, queue)
 
-    return schedule, len(rows)
+    return schedule
 
 
 def _build_beat_schedule_fallback() -> dict:
@@ -179,28 +180,18 @@ def _build_beat_schedule_fallback() -> dict:
 
 
 def build_beat_schedule() -> dict:
-    """Строит beat_schedule:
-    - Из DB (job_settings) если DB reachable И rows > 0
-    - Env-based fallback ТОЛЬКО когда DB unreachable ИЛИ table пустая (fresh install)
-    - Пустой schedule с rows>0 (все jobs disabled намеренно) — RESPECT, без fallback
+    """Строит beat_schedule из DB (job_settings) + добавляет hardcoded entries.
 
-    Всегда добавляет hardcoded entries поверх (refresh-analytics, OSM POI/noise,
-    nspd cleanup) — они не управляются через job_settings.
+    `_build_beat_schedule_from_db` использует `get_all` который сам fallback'ает на
+    _DEFAULTS при DB unreachable / fresh install → возвращает 4 synthetic rows
+    (scrape_kn + objective_sync enabled). То есть schedule из DB-builder ПУСТ
+    только когда оператор явно disabled все cron-able jobs через UPDATE
+    job_settings — это **намерение**, респектим без env-fallback.
+
+    Hardcoded entries (refresh-analytics, OSM POI/noise, nspd cleanup) добавляются
+    ВСЕГДА — они не управляются через job_settings.
     """
-    schedule: dict = {}
-    rows_seen = 0
-    db_reachable = True
-    try:
-        schedule, rows_seen = _build_beat_schedule_from_db()
-    except Exception as e:
-        logger.error(
-            "build_beat_schedule: DB unreachable: %s — fallback на env vars (safety net)", e
-        )
-        db_reachable = False
-
-    if not db_reachable or rows_seen == 0:
-        # DB недоступна ИЛИ fresh install (job_settings пустая) → env-based safety net
-        return _build_beat_schedule_fallback()
+    schedule = _build_beat_schedule_from_db()
 
     # Всегда добавляем refresh_analytics (этот job нет в job_settings,
     # он технический и не требует конфигурации через UI).