Prod prerequisites identified in deep review of the scheduler automation:
- data/sql/122: GRANT SELECT ON rosreestr_deals TO tradein_fdw_reader.
scheduler import reads gendesign.rosreestr_deals via FDW, but the reader
role was REVOKE ALL (100_tradein_fdw_role.sql) with no grant → import
would fail "permission denied for table rosreestr_deals". Single parent
grant suffices for declarative partitioning.
- tradein 072: seed next_run_at = next night-window (tomorrow + window_start
hour, pinned UTC) instead of NULL. NULL made get_due_schedules() fire both
rows within ~1 tick of deploy — outside the night window and (for cian)
before the FDW grant lands. Stays enabled; just shifts first fire to night.
Оба источника данных до этого требовали ручного запуска (HTTP-запрос в admin UI
и bash-скрипт на хосте соответственно). Теперь оба интегрированы в in-app scheduler
(тот же механизм что avito_city_sweep) — запускаются автоматически ночью.
#560 (cian_history_backfill):
- Window 02:00–05:00 UTC; pre-check verify_session() перед claim'ом слота —
если куки истекли, run не создаётся, отправляется GlitchTip capture_message.
- Вызывает существующий backfill_cian_history() как есть; checkpoint через
update_heartbeat() до и после вызова (для zombie-detection).
#563 (rosreestr_dkp_import):
- Window 04:00–06:00 UTC; sync функция в run_in_executor (DB-only, нет HTTP).
- Cursor-based пагинация (WHERE id > last_id ORDER BY id LIMIT batch_size),
heartbeat = checkpoint каждый батч (~2000 строк по умолчанию).
- SAVEPOINT per row через begin_nested() — один сбойный row не откатывает батч.
- Идемпотентен: ON CONFLICT (dedup_hash) DO NOTHING; dedup_hash = md5('ros:dkp:'+id)
соответствует Fix#549.
- Cleanup при старте: удаляет legacy rows address='Екатеринбург, реальная сделка'.
- Координаты NULL — геокодинг остаётся ручным follow-up.
Migration 072: seed rows scrape_schedules + foreign table gendesign_rosreestr_deals
(через gendesign_remote FDW server, настроен в 060).
