hyungi cb7c0fdc4f fix(workers): blocking I/O off-thread — watch_inbox·getaddrinfo·file stream (R5) ...

AsyncIOScheduler 가 FastAPI lifespan 과 같은 이벤트 루프를 공유하는데 동기 blocking
I/O 가 루프를 점유 → 같은 루프의 모든 1분 주기 consumer + FastAPI 요청 동시 정지.
- watch_inbox: NFS rglob walk + GB 파일 SHA-256(file_hash)을 asyncio.to_thread 오프로드.
  스캔 루프가 순차라 file_hash 직렬화 유지(병렬 해싱 X = NFS 2.5GbE 대역폭·메모리 blowup 방지).
- news create_source: validate_feed_url 의 getaddrinfo(blocking DNS) off-thread.
- storage/local stream: 청크 f.read off-thread.
marker_worker/mailplus to_thread 컨벤션 재사용. daily_digest blocking 은 R8(TZ)과 한 패스.

검증: py_compile 통과.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

2026-06-16 13:35:44 +09:00

..

__init__.py

feat(documents): S1 dedup·office-md·storage scaffold (B/C/D/E)

2026-06-08 03:05:30 +00:00

base.py

feat(documents): S1 dedup·office-md·storage scaffold (B/C/D/E)

2026-06-08 03:05:30 +00:00

local.py

fix(workers): blocking I/O off-thread — watch_inbox·getaddrinfo·file stream (R5)

2026-06-16 13:35:44 +09:00

nas_api.py

feat(documents): S1 dedup·office-md·storage scaffold (B/C/D/E)

2026-06-08 03:05:30 +00:00