2 Commits

Author	SHA1	Message	Date
민헌	463416c3a2	fix(lps): 워커 행(hang) 3중 방어 — 잡 데드라인·웜업 타임아웃·정리 루프 격리 ... 부하테스트(N=10) 실측: 쿠팡 브라우저 재기동 경로 행으로 워커 2/3가 12~15분 정지(쿠팡 검색 1콜 880s), heartbeat 가 lease 를 계속 갱신해 reaper 회수 불가 + stuck_running=0 으로 관측 사각. 이에 대한 방어: - P1 잡 데드라인: runner._process 에 wait_for(기본 300s, env LPS_JOB_DEADLINE_SEC) — 초과 시 취소·fail → 백오프 재큐/DEAD - 웜업 시도당 60s 타임아웃 — 웜업이 어댑터 락을 쥔 채 행하면 그 워커의 실 검색이 전부 락 대기로 동반 정지(실측 케이스) - P2 browser reaper: close_if_idle 에 60s 타임아웃 — 한 어댑터 close 행이 정리 루프 전체를 멈추는 것 방지(실측 케이스) - P3 stuck_running: lease 만료 OR 실행 10분 초과(run_started_at) — 행 상태에서도 지표·알림에 잡히게 테스트 5건 추가(데드라인 DEAD/재큐, stuck 지표, reaper 격리) Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>	2026-07-10 11:27:03 +09:00
민헌	abcb58ba05	feat(lps): 워커 루프 + LISTEN/NOTIFY — 큐 소비 파이프라인 가동 ... 큐를 실제로 돌린다: 적재 → 워커 claim → 핸들러 실행 → 결과 저장 → DONE. API(적재)와 워커(소비)를 분리 프로세스로(코드베이스 공유, 독립 스케일). - worker/notify: 전용 asyncpg LISTEN 리스너. enqueue 에서 pg_notify → 유휴 워커 즉시 기상(폴링 제거) - worker/runner: Worker(claim→처리, 처리중 heartbeat 로 lease 갱신, complete/fail) + run_reaper - worker/handlers: job_type 별 핸들러(주입식). SEARCH=소스 어댑터 검색→정규화 결과 - worker_main: API 분리 워커 진입점(브라우저 무거워 기본 동시성 1) - job_crud.enqueue: 삽입 시 pg_notify (중복 스킵 시엔 미발생) - tests: drain→DONE·실패→재시도→dead·reaper 회수 후 재처리·NOTIFY 기상 4건 (전체 20/20) - 라이브 E2E 확인: 적재→워커가 실제 쿠팡 검색(8건)→DONE Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>	2026-07-08 16:58:58 +09:00