aj`S 8UdZddlmZddlZddlmZmZddlmZmZm Z m Z m Z ddl m Z mZmZmZddlmZmZmZmZmZddlmZdd lmZd Zd ed <d Zd ed<dZd ed<dZd ed<dZ d ed<dZ!d ed<dZ"d ed<e#eeeee e!e"hZ$ded<dZ%d ed<dZ&d ed<dZ'd ed<d Z(d ed!<d"Z)d ed#<ejTd$%Gd&d'Z+ d1d(Z,d2d)Z-d3d*Z.d4d+Z/dd,d,d-dddddd$d. d5d/Z0gd0Z1y)6uanu_v2.ci_gemini_watcher_runner — CI + Gemini watcher 단일 멱등 cycle runner (task-2718). 회장 인가: 기존 anu_v2 빌딩블록을 import/call 로 결선하는 얇은 runner. 신규 로직 최소화. 실제 GitHub write 0 (decision/dry-run only). task-2718. 책임: - 기존 빌딩블록(freshness_checker / validate_decision / AutoGeminiTriage / ExecutorScheduler) 을 결선해 단일 1회 실행 → terminal enum 1 개 반환. - 세션-bound sleep/polling 절대 금지 (1 회 실행 → 즉시 반환). - 실제 GitHub write 0 (github_writes 카운터 항상 0 유지). - 모든 부수효과는 주입형 callable 로 추상화. one-way isolation: anu_v2/* 만 import. 외부 (utils/dispatch/scripts/dashboard) 의존성 0. ) annotationsN)datetimetimezone)AnyCallableFinalMappingSequence)check_gemini_evidence_fresh RESULT_FRESH RESULT_STALERESULT_NO_REVIEW)validate_decision SCHEMA_NAMEALLOWED_ACTIONALLOWED_COMMENT_BODYDecisionInvalidError)AutoGeminiTriage)ExecutorSchedulerMERGE_READY_CANDIDATEz Final[str]TERMINAL_MERGE_READY_CANDIDATE LOOP_BOUNDARYTERMINAL_LOOP_BOUNDARYBLOCKED_BY_CAPABILITYTERMINAL_BLOCKED_BY_CAPABILITY GEMINI_EXTERNAL_TRIGGER_REQUIRED)TERMINAL_GEMINI_EXTERNAL_TRIGGER_REQUIREDCI_FAILED_NON_REMEDIABLE!TERMINAL_CI_FAILED_NON_REMEDIABLEHOLD_STALE_HEADTERMINAL_HOLD_STALE_HEADHOLD_SCOPE_UNCLEANTERMINAL_HOLD_SCOPE_UNCLEANzFinal[frozenset[str]] ALL_TERMINALSALLOW_OWNER_TRIGGERTRIGGER_ALLOW_OWNEROWNER_TRIGGER_DEDUPEDTRIGGER_OWNER_DEDUPEDTRIGGER_EXTERNAL_REQUIREDSELF_GEMINI_TRIGGER_BLOCKEDTRIGGER_SELF_BLOCKEDNONE TRIGGER_NONET)frozenceZdZUdZded<ded<ded<ded<ded<ded <ded <d ed <d ed <ded<ded<ded<ddZy) WatchResulturun_watch_cycle 결과 객체 (frozen — 불변 값 객체). fields: terminal : ALL_TERMINALS 중 하나. trigger_decision: TRIGGER_* 상수 중 하나. pr_number : 평가된 PR 번호. expected_head : queue/expected head SHA (입력). actual_head : gh_runner 로 실측한 PR HEAD SHA. ci_state : CI rollup state ("SUCCESS" | "FAILURE" | "PENDING" | "UNKNOWN"). gemini_freshness: FRESH | STALE | NO_REVIEW | "UNKNOWN". triage_summary : triage_batch 결과 count 요약 (FRESH 시 채움). decision_json : ALLOW_OWNER_TRIGGER 시 validate 통과 decision dict. github_writes : 항상 0 (실 write 0 입증). dry_run : 기본 True. reason : 짧은 사유 문자열. strterminaltrigger_decisionint pr_number expected_head actual_headci_stategemini_freshness dict | Nonetriage_summary decision_json github_writesbooldry_runreasonc,tj|S)u:JSON 직렬화용 dict 반환 (dataclasses.asdict 기반).) dataclassesasdict)selfs 6/home/jay/workspace/anu_v2/ci_gemini_watcher_runner.pyto_jsonzWatchResult.to_jsonks!!$''N)returndict)__name__ __module__ __qualname____doc____annotations__rFrGrEr0r0KsQ"MNM M K(rGr0c(|j||S)u^ExecutorScheduler._has_active_trigger_for_head 를 thin-wrap 하는 dedupe 헬퍼. 프로덕션: run_watch_cycle(dedupe_checker=lambda pr, sha: scheduler_backed_dedupe(sched, pr_number=pr, head_sha=sha)) 테스트 : dedupe_checker=mock 주입. ExecutorScheduler 구성은 runner 외부에서 담당 (thin runner 책임 최소화). )r5head_sha)_has_active_trigger_for_head) schedulerr5rQs rEscheduler_backed_deduperTts  1 1IPX 1 YYrGchtjtjj dS)uH현재 UTC ISO8601 문자열 반환 (clock 주입 없을 때 기본값).seconds)timespec)rnowrutc isoformatrOrGrE_now_isor[s# << % / / / CCrGct|trt|dk7rt|d||j }t d|Drt|d||S)uB40-char hex SHA 검증 후 lower 정규화. 실패 시 ValueError.(u7 는 40-char hex SHA 문자열이어야 합니다, got c3$K|]}|dv yw)0123456789abcdefNrO).0cs rE z$_validate_hex_sha..s 811& & 8su+ 는 40-char hex SHA (hex chars only), got ) isinstancer1len ValueErrorlowerany)valuenamelowereds rE_validate_hex_sharkse eS !SZ2%5D6!XY^XabcckkmG 8 88D6!LUIVWW NrGct|jdxsgt|jdxsgt|jdxsgdS)u3triage_batch 결과에서 count 요약 dict 생성.applied dismissed escalated) applied_countdismissed_countescalated_count)rdget)outs rE_triage_count_summaryrusPSWWY/526sww{39r:sww{39r: rGunknown) clockownerrepotask_id owner_proofdedupe_checkerrecord_triggertriage audit_writerr?c ||nt}tddddddd d> fd}ttrttsdkrt dt d }|ttd Sd }t|jj}||k7r|t|d |ddd|dddSd xsg}t|}|Dcgc] }||vs| }}|r3|t|dt|d|ddt|dkDrdndSd xsi}|jdd}|dk(r"|jdds|t ||dSfd}t#||||}|j$}|j$t&k(rd xsg}| }|| | nd!}t)||"}|j+||}t-|} |jd#xsg}!|!r|t.|||| d$t|!d%&S|d'k(r|t0|||| d(&S|t.|||| d)|d*&S|'|jd+r|tt2|||d,-St |xrRt |jd.xr6t |jd/xst |jd0}"|"s|t4t6|||d1-S| | |nd}#|#r |t4t8|||d2d3|ddd4-St:||d5d5ddt<t>d5d6 }$ tA|$|7| | ||t4tH||||$d:d3|ddd;|j$d< =Scc}w#tB$r:}%|tt|||d8|%jDd9|%jF-cYd}%~%Sd}%~%wwxYw)?uCI + Gemini watcher 단일 멱등 cycle runner (1회 실행 → terminal enum 1개 반환). 세션-bound sleep/polling 절대 금지. github_writes 는 항상 0. 결정 로직 순서는 명세 §결정로직 1~7 1:1. Args: pr_number : 평가 대상 PR 번호 (positive int). expected_head : queue/expected head SHA (40-char hex). expected_files : 기대 diff 파일 경로 목록 (scope 검사 기준). gh_runner : 주입형 부수효과 callable (op 분기 — 명세 §gh_runner 참조). clock : UTC ISO 문자열 반환 callable. None 이면 datetime.now(UTC) 사용. owner : GitHub owner (freshness checker 에 전달). repo : GitHub repo (freshness checker 에 전달). task_id : 감사 기록용 task ID. owner_proof : OWNER 권한 증빙 dict (is_owner/admin/push/self_key). None 가능. dedupe_checker : (pr_number, head_sha) → bool. 이미 trigger 된 head 중복 방지. record_trigger : (pr_number, head_sha) → None. dry-run trigger 기록 (부수효과 없음). triage : AutoGeminiTriage 인스턴스. None 이면 내부 생성. audit_writer : triage 내부 audit 기록용 callable. dry_run : 기본 True (실 write 0 보장). Returns: WatchResult (frozen dataclass). Raises: ValueError: pr_number <= 0 또는 expected_head 형식 오류. NrvUNKNOWN)r3r7r8r9r;r<r@r7cX|tvs Jd|dt|| |||||d| S)u=내부 WatchResult 생성 헬퍼. github_writes 는 항상 0.z terminal z not in ALL_TERMINALSr) r2r3r5r6r7r8r9r;r<r=r?r@)r$r0) r2r3r7r8r9r;r<r@r?r6r5s rE_makezrun_watch_cycle.._makesS=(WIh\AV*WW(-'#-)'  rGru1pr_number 은 양의 정수여야 합니다, got r6u-gh_runner 이 None — capability gate 차단)r3r@)r5z actual HEAD (z...) != expected HEAD (u...) — stale head)r7r@ diff_pathsudiff 에 scope 외 경로 u 건 포함: z... ci_rollupstateFAILURE remediableFu4CI FAILURE (non-remediable) — 자동 복구 불가)r7r8r@cd||S)Nreviews)methodpathrO)rr gh_runners rEz!run_watch_cycle..(sYydKrG)r5current_head_sha github_apiryrzfindingscy)NrO)recs rErz!run_watch_cycle..<srG)rr{roztriage escalated u건 — LOOP_BOUNDARY)r7r8r9r;r@SUCCESSu3triage clean + CI SUCCESS → MERGE_READY_CANDIDATEutriage clean 이지만 CI=u — 보수적 LOOP_BOUNDARYself_keyu8owner_proof.self_key=True — self Gemini trigger 차단)r3r7r8r9r@is_owneradminpushuAowner proof 없음/불충분 — GEMINI_EXTERNAL_TRIGGER_REQUIREDz(pr=z, head=u#...) 이미 trigger 됨 — DEDUPEDT) schemar{pr current_head queue_headcurrent_head_confirmedgemini_evidence_freshnudge_count_for_pr_headallowed_action comment_bodyallowed)current_head_actualuvalidate_decision 실패 code=z: uowner trigger 허가 — pr=z..., freshness=z , dry_run=)r3r7r8r9r<r@)r2r1r3r1r7r1r8r1r9r1r;r:r<r:r@r1rHr0)%r[r-rcr4r>rerkrr1rfstripr!setr#rdrsrr statusr r triage_batchrurrr+rr)r(rrrrrcodemessager&)&r5r6expected_filesrrxryrzr{r|r}r~rrr?_clockrexpected_head_normactual_head_rawr7rexpected_files_setp out_of_scopecir8 _github_apifrr9r_triage _audit_writer triage_outsummary unresolvedralready_triggereddecisionexcs&`` ` ` rErun_watch_cyclers>Z'UXF !-! )&*%)         $ #    : i %It)D UVLYMZ[[*=/J *)B  %]iHOo&,,.446K(( $# BQ01""4Ra"8!99LN   &liHNBJ^,)I!Q6H-HAILI '#,S->,?|#&L0AA0Eu2&NP    :@bBFF7I.H9RVVL%%@ -#I    L %$   BII yyL (yIOR ? , 8 ?O '*G #//.I ' 3%>>+6<" &'!!1&*3z?*;;PQ   y .'!!1&L   "#-"/z9UV   ;??:#> *1#-M    [ N , - N +//'* + LtKOOF4K/L  56#-V   3A2Ly+.RW 52#-)GKO+<<_`   #"&!&#$(, H  ( D!y+. 1,)*9+W[!_)rHr1)rhr1rir1rHr1)rtrIrHrI)r5r4r6r1rz Sequence[str]rzCallable[..., Any]rxzCallable[[], str] | Noneryr1rzr1r{r1r|zMapping[str, Any] | Noner}z!Callable[[int, str], bool] | Noner~z!Callable[[int, str], None] | NonerzAutoGeminiTriage | Nonerz*Callable[[Mapping[str, Any]], None] | Noner?r>rHr0)2rM __future__rrBrrtypingrrrr r (anu_v2.gemini_evidence_freshness_checkerr r r ranu_v2.owner_trigger_decisionrrrrranu_v2.auto_gemini_triageranu_v2.executor_schedulerrrrNrrrrr!r# frozensetr$r&r(r)r+r- dataclassr0rTr[rkrur__all__rOrGrErs# #':: 77.E D%4 4-D D8Z):Z0J!:J'8*8*>Z>'0""-%2( $#8Z7$;z;(J:J#@j@! j!d#!(!($!(P Z  Z Z Z  Z(D &'+,08<8<&*?C^^^" ^ " ^ $ ^ ^ ^^*^6^6^ $^=^^ !^J  rG