Mj: UdZddlmZddlZddlmZmZddlmZmZddl m Z m Z m Z dZ ded <d Zded <d Zded <dZded<dZded<dZded<dZded<dZded<ee eeeeeeehZded<eeehZded<dZded<ej4dZded <ed!"Gd#d$Zed!"Gd%d&Zed!"Gd'd(Zd0d)Zd1d*Z dd+d2d,Z!Gd-d.Z"gd/Z#y)3uanu_v2.idle_pr_diagnoser — OPEN PR 상태 머신 분류 (task-2556 §2 / §3 / §4). 회장 §명시 2026-05-12 KST (task-2556 12 필수 §2~§4): §2 task_id / head_sha / CI / Gemini evidence 상태 진단 — 각 OPEN PR별 상태 머신 분류 §3 FIRST_GEMINI_TRIGGER_MISSING 감지 — PR createdAt + 30min 경과 + Gemini reviews 0 §4 GEMINI_STALE_ON_HEAD 감지 — PR head SHA != Gemini review commit_id 본 모듈은 입력 PR 메타데이터를 정적으로 분석해 8 가지 상태 코드 중 하나를 반환한다. 부수효과 0 (network/disk 접근 없음). 외부에서 ``gh pr list --json ...`` 결과를 정규화해 넘기면, 본 모듈은 순수 함수처럼 상태를 분류한다. 상태 머신 (8 states): - ``WITHIN_GRACE_PERIOD``: PR createdAt 후 30분 이내 (1st Gemini auto-trigger 대기) - ``FIRST_GEMINI_TRIGGER_MISSING``: createdAt+30min 경과 + reviews 0 → owner trigger 필요 - ``GEMINI_STALE_ON_HEAD``: head SHA != latest review commit_id → owner trigger 필요 - ``GEMINI_FRESH_ON_HEAD``: head SHA == latest review commit_id → ready for merge gate - ``CI_FAILED``: ci.required_all_success == False → 후속 작업은 task 봇 책임 - ``MISSING_TASK_ID``: branch 에서 task_id 추출 실패 → 격리 위반 - ``UNKNOWN_STATE``: 위 어디에도 해당 없음 (fail-closed default) - ``OWNER_TRIGGER_REQUIRED``: aggregated 결과 (FIRST_GEMINI_TRIGGER_MISSING | GEMINI_STALE_ON_HEAD) — scheduler 가 owner trigger 호출 대상 one-way isolation: anu_v2/ 외부 import 금지. ) annotationsN) dataclassfield)datetimetimezone)AnyFinalSequenceWITHIN_GRACE_PERIODz Final[str]STATE_WITHIN_GRACE_PERIODFIRST_GEMINI_TRIGGER_MISSING"STATE_FIRST_GEMINI_TRIGGER_MISSINGGEMINI_STALE_ON_HEADSTATE_GEMINI_STALE_ON_HEADGEMINI_FRESH_ON_HEADSTATE_GEMINI_FRESH_ON_HEAD CI_FAILEDSTATE_CI_FAILEDMISSING_TASK_IDSTATE_MISSING_TASK_ID UNKNOWN_STATE STATE_UNKNOWNOWNER_TRIGGER_REQUIREDSTATE_OWNER_TRIGGER_REQUIREDzFinal[frozenset[str]] ALL_STATESOWNER_TRIGGER_INVOKING_STATESiz Final[int]GRACE_PERIOD_SECONDSz%^(?:task/)?(?Ptask-\d+(?:\+\d+)?)zFinal[re.Pattern[str]]_TASK_BRANCH_RET)frozenc.eZdZUdZded<ded<ddZy)GeminiReviewMetau0Gemini review 한 건 (PR 상 commented review).str commit_id submitted_atcNt|jtrt|jdk7r t d|jj }t d|Dr t dt|jtr |js t dy)N(z!commit_id must be 40-char hex SHAc3$K|]}|dv yw0123456789abcdefN.0cs I/home/jay/workspace/.worktrees/task-2699-dev1/anu_v2/idle_pr_diagnoser.py z1GeminiReviewMeta.__post_init__..Ts.wsJqq**Jr0z!head_ref must be non-empty stringz,created_at must be non-empty ISO 8601 string) r1rErDrKr3rFr"r2r5r4rGrHr6s r.r8zIdlePRSnapshot.__post_init__rs$++s+z$++t/LPTP[P[_`P`:; ;$---T]]1Cr1I?@ @ JDMM4G4G4IJ J?@ @$---T]]@A A$//3/tKL L8Gr9Nr:) r=r>r?r@rArtuplerJrLrNrOr8r*r9r.rCrCZsR  KMMO383ON0O$)T)E3M4 Mr9rCcreZdZUdZded<ded<ded<ded<ded <ded <ded <dd Zedd Zy)IdlePRDiagnosisu 진단 결과 — 단일 상태 + 부가 정보 + scheduler 가 사용할 task_id. Attributes: state: ``ALL_STATES`` 중 하나. task_id: head_ref 에서 추출된 task id (e.g. "task-2556"); 추출 실패 시 "". pr_number: PR 번호. head_sha: PR head SHA (lower-case). latest_gemini_commit_id: 가장 최근 gemini review commit_id (없으면 None). reason: 사람이 읽을 수 있는 한 줄 사유. elapsed_since_created_seconds: createdAt → now_iso 경과 초. r"rNtask_idrD pr_numberrF str | Nonelatest_gemini_commit_idreasonelapsed_since_created_secondscf|jtvrtdtd|jy)Nzstate must be one of z, got )rNrr3rRs r.r8zIdlePRDiagnosis.__post_init__s0 ::Z '4ZLtzznUV V (r9c&|jtvS)uHscheduler 가 owner trigger runner 를 호출해야 하는 상태인지.)rNrrRs r.requires_owner_triggerz&IdlePRDiagnosis.requires_owner_triggerszz:::r9Nr:)r;rK)r=r>r?r@rAr8propertyr^r*r9r.rUrUsH  J LNM'' K#&&W;;r9rUczt|tr|sytj|}|sy|j dS)ubranch 이름에서 task id 추출. 실패 시 빈 문자열. e.g. ``task/task-2556-dev5`` → ``task-2556``. e.g. ``task/task-2556+1-dev5`` → ``task-2556+1``. id)r1r"rmatchgroup)rGms r.extract_task_idrfs7 h $Hh'A  774=r9cFt|tr|s td|jdr|j ddn|}t j |}|j |j tj}|jtjS)uDISO 8601 (Z 또는 +00:00) → datetime(UTC). 실패 시 ValueError.zISO 8601 string requiredZz+00:00)tzinfo) r1r"r3endswithreplacer fromisoformatrirutc astimezone)value normalizeddts r._parse_iso_utcrrsx eS !344161DsH-%J    +B yy ZZx||Z , == &&r9nowct|}| t|}n#tjtj}||z }t |j S)ucreatedAt 이후 경과 초 (정수). now 미지정 시 ``datetime.now(UTC)``. 음수가 반환되면 (시계 skew) caller 는 0 으로 정규화하여 사용. )rrrrtrrmrD total_seconds)rHrt created_dtnow_dtdeltas r.elapsed_seconds_sincerzsM  +J $hll+ Z E u""$ %%r9cNeZdZdZedddZdd d dZdd d dZy) IdlePRDiagnoseruOPEN PR snapshot 을 8 상태 중 하나로 분류 (회장 §2 / §3 / §4 1:1). 설계: - 순수 함수형. 입력 ``IdlePRSnapshot`` + 선택적 ``now`` ISO 문자열. - 외부 부수효과 0. - 상태 우선순위 (위 → 아래로 평가, 첫 match 가 결과): 1. MISSING_TASK_ID (격리 위반 — head_ref 파싱 실패) 2. CI_FAILED (회장 §명시 외 영역 — task 봇 책임) 3. WITHIN_GRACE_PERIOD (PR createdAt 후 30분 이내) 4. FIRST_GEMINI_TRIGGER_MISSING (reviews 0 + 30min 경과) 5. GEMINI_STALE_ON_HEAD (latest review commit_id != head_sha) 6. GEMINI_FRESH_ON_HEAD (latest review commit_id == head_sha) 7. UNKNOWN_STATE (fail-closed default) 회장 §3 정확 일치: PR createdAt + 30min 경과 + Gemini reviews 0 → FIRST_GEMINI_TRIGGER_MISSING. 회장 §4 정확 일치: head_sha != latest commit_id → GEMINI_STALE_ON_HEAD. )grace_period_secondscRt|tr|dkr td||_y)Nrz-grace_period_seconds must be non-negative int)r1rDr3_grace_period_seconds)r6r}s r.__init__zIdlePRDiagnoser.__init__s).48Lq8PLM M%9"r9Nrsc t|ts tdt|j}|j j }d}|jr'|jdjj } t|j|}t|d}|s.ttd|j||d|jd| S|j s tt"||j||d | S||j$kr1tt&||j||d |d |j$d | S|js1tt(||j|dd |d|j$d| S|J||k7r-tt*||j||d|ddd|ddd| Stt,||j||d|ddd| S#t$rd}YPwxYw)u"상태 분류. 회장 §2~§4 1:1.z(snapshot must be IdlePRSnapshot instanceNrsrraz head_ref=z# does not match task branch pattern)rNrVrWrFrYrZr[uNci_required_all_success is False — task bot must fix CI before owner triggerzelapsed=zs < grace_period=u's — 1st Gemini auto-review 대기 중zs >= grace_period=u/s + 0 Gemini reviews — owner trigger requiredz head_sha=z != latest_gemini_commit=u7 — follow-up commit 후 stale, owner trigger requiredz"head_sha == latest_gemini_commit (u) — ready for merge gate)r1rC TypeErrorrfrGrFr4rJr#rzrHr3maxrUrrErLrrr rrr)r6snapshotrtrVrFlatest_commit_idelapseds r.diagnosezIdlePRDiagnoser.diagnoses[(N3FG G!("3"34$$**,'+  " "'66r:DDJJL  +H,?,?SIGgq/"+"//!(8"8#4#4"77Z[.5 //"%"//!(8g.5  T// /"/"//!(8wi'89S9S8TU<=/6  &&"8"//!(,wi'9$:T:T9UVBC/6   +++ x '"0"//!(8! ~-FGWXZYZG[F\]MN/6  ,oo$47! ~E_`*1  W G sG G)(G)cN|Dcgc]}|j||c}Scc}w)u여러 PR snapshot 을 일괄 진단. 동일한 ``now`` 가 모든 PR 에 적용된다. scheduler 는 본 메서드 반환 결과를 보고 ``requires_owner_trigger`` 인 PR 만 owner trigger 호출 대상으로 골라낸다. rs)r)r6 snapshotsrtsnaps r. diagnose_allzIdlePRDiagnoser.diagnose_allKs&:CC d ,CCCs")r}rDr;r<)rrrtrXr;rU)rzSequence[IdlePRSnapshot]rtrXr;zlist[IdlePRDiagnosis])r=r>r?r@rrrrr*r9r.r|r|sg$7K: e e  e  e V D+ D D  Dr9r|)r rrrrrrrrrrr!rCrUr|rfrz)rGr"r;r")ror"r;r)rHr"rtrXr;rD)$r@ __future__rre dataclassesrrrrtypingrr r r rArrrrrrr frozensetrrrcompilerr!rCrUrfrrrzr|__all__r*r9r.rs2# (''' )>:=1O"JO)?J?)?J?))$5z5+ z++CjC$-&  / % ! 8A&B84 $+j*+5"**,+' $ O O O  $!M!M!MH $;;;D 'AE &"JDJDZ r9