Hyungi Ahn
bbd92a840a
PR-Worker-Pool-Registry-1A (scaffold only, no runtime activation). 신규: - migrations/270~274 (1 statement/1 file 강제): worker_capabilities + 2 idx + worker_heartbeats + 1 idx - app/models/worker_pool.py: WorkerCapability + WorkerHeartbeat ORM (queue.py 패턴) - app/api/internal_worker.py: 5 endpoint 모두 _stub_503() — register/heartbeat/claim/result/drain - tests/test_internal_worker_stub.py: 503 응답 smoke (inline ASGI client, DB 의존 0) 수정: - app/main.py: import + include_router 각 1줄 (prefix=/internal/worker, internal_study 일관) scaffold-first + phase-gate-material-first 강제 (worker-pool-policy §1, §12): - 인증 dependency 0 (1B 에서 JWT + require_worker_user) - ProcessingQueue 변경 0 (방향 b: worker_jobs 별 table = 1B) - LLM 호출 0 / canonical DB 변경 0 / 운영 자동 분기 0 회귀 0 (1주 안전망 = app/main.py.pre-registry-1a.20260518). plan: ~/.claude/plans/floofy-exploring-mitten.md Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
18 lines
945 B
SQL
18 lines
945 B
SQL
-- 2026-05-18 PR-Worker-Pool-Registry-1A: worker_heartbeats 테이블 신규.
|
|
-- worker 가 30~60s 주기로 status 발신 (worker-pool-policy §7).
|
|
-- append-only. 운영 alive 판정 = (worker_id 별 최신 row).heartbeat_at > now() - interval '10 min'.
|
|
-- retention 정책은 별 PR (PR-LLM-Router-Observability-1 또는 동등).
|
|
-- 1A 단계: schema only (heartbeat endpoint 503 stub). 활성화 = 1B.
|
|
-- current_job_id 는 1A 단계에서 plain BIGINT (FK 없음). 1B 의 worker_jobs 마이그레이션 후 FK 추가 검토.
|
|
|
|
CREATE TABLE IF NOT EXISTS worker_heartbeats (
|
|
id BIGSERIAL PRIMARY KEY,
|
|
worker_id TEXT NOT NULL REFERENCES worker_capabilities(worker_id) ON DELETE CASCADE,
|
|
heartbeat_at TIMESTAMPTZ NOT NULL DEFAULT now(),
|
|
status TEXT NOT NULL,
|
|
current_job_id BIGINT,
|
|
battery TEXT,
|
|
thermal TEXT,
|
|
raw_payload JSONB NOT NULL DEFAULT '{}'::jsonb
|
|
);
|