fix(scheduler): atomic _claim_run via advisory xact lock (Refs #750) #752

Merged
bot-reviewer merged 1 commit from fix/750-scheduler-atomic-claim into main 2026-05-30 16:04:33 +00:00

1 commit

Author SHA1 Message Date
9f950a5f17 fix(scheduler): atomic _claim_run via advisory xact lock (Refs #750)
Конкурентные scheduler-тики одного source (redeploy-overlap старого+нового
контейнера / 2 реплики) оба проходили has_running_run pre-check и запускали
ДВОЙНОЙ city-sweep → 2x rate к Avito/Cian → бан скрапера.

Path A: transaction-scoped pg_try_advisory_xact_lock(hashtext(source)) после
pre-check сериализует claim; non-blocking (lock занят → return None). Под локом
double-checked has_running_run (running мог появиться в окне pre-check→lock).
Лок авто-снимается на commit/rollback.

Path B (partial unique index WHERE status='running') отклонён: миграция могла
упасть на deploy если dirty-данные уже содержат >=2 running-строк на source
(ровно то, что баг и создаёт) — рискованно перед demo.

Tests: double-call→один run; lock unavailable→skip; running-under-lock→rollback+skip.
2026-05-30 19:01:37 +03:00