jK .UdZddlmZddlZddlmZmZddlmZmZddl m Z m Z m Z ddl mZdZd ed <d Zd ed <d Zd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<eeeeeeeeeeh Zded<eeehZded<dZded <eZded!<ej<d"Zd#ed$<ed%&Gd'd(Z ed%&Gd)d*Z!ed%&Gd+d,Z"d4d-Z#d5d.Z$dd/d6d0Z%Gd1d2Z&gd3Z'y)7u anu_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 task-2563 회장 §명시 2026-05-13 KST (OWNER_TRIGGER_ONLY_CAPABILITY hardening §1): - ``FIRST_TRIGGER_PENDING`` 신규 상태 추가 — PR open 직후 짧은 시간 동안 Gemini external trigger 대기. ``FIRST_GEMINI_TRIGGER_MISSING`` 은 polling_policy.FIRST_TIMEOUT_SECONDS (1800s) 경과 후에만 확정 (조기 owner_trigger 호출 위험 차단). - ``FIRST_TRIGGER_PENDING_WINDOW_SECONDS`` (default 300s) 짧은 grace window. 이 구간을 벗어나면 PENDING 으로 분류되며, scheduler 는 ``dispatch_decision.owner_trigger_fast_path == true`` 일 때만 조기 dispatch 허용 (그 외는 SKIP). 본 모듈은 입력 PR 메타데이터를 정적으로 분석해 9 가지 상태 코드 중 하나를 반환한다. 부수효과 0 (network/disk 접근 없음). 외부에서 ``gh pr list --json ...`` 결과를 정규화해 넘기면, 본 모듈은 순수 함수처럼 상태를 분류한다. 상태 머신 (9 states): - ``WITHIN_GRACE_PERIOD``: PR createdAt 후 ``FIRST_TRIGGER_PENDING_WINDOW_SECONDS`` (default 300s = "PR open 직후 짧은 시간") 이내 — 어떤 trigger 결정도 보류. - ``FIRST_TRIGGER_PENDING``: 짧은 grace window 경과 + ``FIRST_TIMEOUT_SECONDS`` 미경과 + reviews 0 → Gemini external trigger 대기. fast_path=true 일 때만 조기 trigger 가능. - ``FIRST_GEMINI_TRIGGER_MISSING``: ``FIRST_TIMEOUT_SECONDS`` (1800s) 경과 + reviews 0 → 누락 확정, owner trigger 필요 (회장 §3). - ``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)AnyFinalSequence)FIRST_TIMEOUT_SECONDSWITHIN_GRACE_PERIODz Final[str]STATE_WITHIN_GRACE_PERIODFIRST_TRIGGER_PENDINGSTATE_FIRST_TRIGGER_PENDINGFIRST_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_STATESi,z Final[int]$FIRST_TRIGGER_PENDING_WINDOW_SECONDSGRACE_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 :/home/jay/workspace/scripts/../anu_v2/idle_pr_diagnoser.py z1GeminiReviewMeta.__post_init__..ls.sJqq**Jr4z!head_ref must be non-empty stringz,created_at must be non-empty ISO 8601 string) r5rIrHrOr7rJr&r6r9r8rKrLr:s r2r<zIdlePRSnapshot.__post_init__s$++s+z$++t/LPTP[P[_`P`:; ;$---T]]1Cr1I?@ @ JDMM4G4G4IJ J?@ @$---T]]@A A$//3/tKL L8Gr=Nr>) rArBrCrDrErtuplerNrPrRrSr<r.r=r2rGrGrsR  KMMO383ON0O$)T)E3M4 Mr=rGcreZdZUdZded<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&rRtask_idrH pr_numberrJ str | Nonelatest_gemini_commit_idreasonelapsed_since_created_secondscf|jtvrtdtd|jy)Nzstate must be one of z, got )rRrr7rVs r2r<zIdlePRDiagnosis.__post_init__s0 ::Z '4ZLtzznUV V (r=c&|jtvS)uHscheduler 가 owner trigger runner 를 호출해야 하는 상태인지.)rRrrVs r2requires_owner_triggerz&IdlePRDiagnosis.requires_owner_triggerszz:::r=Nr>)r?rO)rArBrCrDrEr<propertyrbr.r=r2rYrYsH  J LNM'' K#&&W;;r=rYczt|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)r5r&r"matchgroup)rKms r2extract_task_idrjs7 h $Hh'A  774=r=cFt|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) r5r&r7endswithreplacer fromisoformatrmrutc astimezone)value normalizeddts r2_parse_iso_utcrvsx eS !344161DsH-%J    +B yy ZZx||Z , == &&r=nowct|}| t|}n#tjtj}||z }t |j S)ucreatedAt 이후 경과 초 (정수). now 미지정 시 ``datetime.now(UTC)``. 음수가 반환되면 (시계 skew) caller 는 0 으로 정규화하여 사용. )rvrrxrrqrH total_seconds)rLrx created_dtnow_dtdeltas r2elapsed_seconds_sincer~sM  +J $hll+ Z E u""$ %%r=cZeZdZdZeed ddZdd d dZdd d dZy) IdlePRDiagnoseruOPEN PR snapshot 을 9 상태 중 하나로 분류 (회장 §2 / §3 / §4 + task-2563 §1). 설계: - 순수 함수형. 입력 ``IdlePRSnapshot`` + 선택적 ``now`` ISO 문자열. - 외부 부수효과 0. - 상태 우선순위 (위 → 아래로 평가, 첫 match 가 결과): 1. MISSING_TASK_ID (격리 위반 — head_ref 파싱 실패) 2. CI_FAILED (회장 §명시 외 영역 — task 봇 책임) 3. WITHIN_GRACE_PERIOD (PR createdAt 후 짧은 grace window 이내; task-2563 §1) 4. FIRST_TRIGGER_PENDING (grace window 경과 + FIRST_TIMEOUT_SECONDS 미경과 + reviews 0) 5. FIRST_GEMINI_TRIGGER_MISSING (FIRST_TIMEOUT_SECONDS 경과 + reviews 0) 6. GEMINI_STALE_ON_HEAD (latest review commit_id != head_sha) 7. GEMINI_FRESH_ON_HEAD (latest review commit_id == head_sha) 8. UNKNOWN_STATE (fail-closed default) 회장 §3 정확 일치: PR createdAt + FIRST_TIMEOUT_SECONDS (1800s) 경과 + Gemini reviews 0 → FIRST_GEMINI_TRIGGER_MISSING (확정). task-2563 §1 1:1: PR open 직후 짧은 시간 + reviews 0 → FIRST_TRIGGER_PENDING (대기). 회장 §4 정확 일치: head_sha != latest commit_id → GEMINI_STALE_ON_HEAD. )pending_window_secondsfirst_timeout_secondsct|tr|dkr tdt|tr|dkr td||kDr td||_||_y)Nrz/pending_window_seconds must be non-negative intz.first_timeout_seconds must be non-negative intz{pending_window_seconds must be <= first_timeout_seconds (short grace window precedes PENDING precedes MISSING confirmation))r5rHr7_pending_window_seconds_first_timeout_seconds)r:rrs r2__init__zIdlePRDiagnoser.__init__sr 0#6:PST:TNO O/59NQR9RMN N !$9 9V (>$&;#r=Nrwct|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||j(krJ|js>tt*||j|dd|j$d|d|j(d| S|js1tt,||j|dd |d|j(d| S|J||k7r-tt.||j||d|ddd|ddd| Stt0||j||d|ddd| S#t$rd}YwxYw)u"상태 분류. 회장 §2~§4 1:1.z(snapshot must be IdlePRSnapshot instanceNrwrrez head_ref=z# does not match task branch pattern)rRrZr[rJr]r^r_uNci_required_all_success is False — task bot must fix CI before owner triggerzelapsed=zs < pending_window=uCs — PR open 직후 짧은 시간, 어떤 trigger 결정도 보류zpending_window=z s <= elapsed=zs < first_timeout=u`s + 0 reviews — Gemini external trigger 대기 (fast_path=true 시에만 owner trigger 허용)zs >= first_timeout=u?s + 0 Gemini reviews — MISSING 확정, 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)r5rG TypeErrorrjrKrJr8rNr'r~rLr7maxrYrrIrPrrr rrrrr)r:snapshotrxrZrJlatest_commit_idelapseds r2diagnosezIdlePRDiagnoser.diagnose s(N3FG G!("3"34$$**,'+  " "'66r:DDJJL  +H,?,?SIGgq/"+"//!(8"8#4#4"77Z[.5 //"%"//!(8g.5  T11 1"/"//!(8wi':4;W;W:XYXY/6   T00 09P9P"1"//!(,%d&B&B%C=QXPYZ''+'B'B&CDef/6   &&"8"//!(,wi':4;V;V:WXRS/6   +++ x '"0"//!(8! ~-FGWXZYZG[F\]MN/6  ,oo$47! ~E_`*1   G sH33 IIcN|Dcgc]}|j||c}Scc}w)u여러 PR snapshot 을 일괄 진단. 동일한 ``now`` 가 모든 PR 에 적용된다. scheduler 는 본 메서드 반환 결과를 보고 ``requires_owner_trigger`` 인 PR 만 owner trigger 호출 대상으로 골라낸다. rw)r)r: snapshotsrxsnaps r2 diagnose_allzIdlePRDiagnoser.diagnose_alls&:CC d ,CCCs")rrHrrHr?r@)rrrxr\r?rY)rzSequence[IdlePRSnapshot]rxr\r?zlist[IdlePRDiagnosis]) rArBrCrDr r rrrr.r=r2rrs0'K%: <!$< # <  <, y y  y  y ~ D+ D D  Dr=r)r rrrrrrrrrrr!r r%rGrYrrjr~)rKr&r?r&)rsr&r?r)rLr&rxr\r?rH)(rD __future__rre dataclassesrrrrtypingrr r anu_v2.polling_policyr r rErrrrrrrr frozensetrrr r!compiler"r%rGrYrjrvr~r__all__r.r=r2rs#J# ('''7 )>:=*AZA1O"JO)?J?)?J?))$5z5+ z++CjC$-&  / % ! 8A&B844:$j9$9j8+5"**,+' $ O O O  $!M!M!MH $;;;D 'AE &"nDnDb r=