j!R UdZddlmZddlZddlmZmZmZmZm Z ddl m Z m Z ddl mZmZmZmZmZddlmZddlmZd Zd ed <d Zd ed <dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<eeeeeeeehZ ded<dZ!d ed<dZ"d ed<dZ#d ed<dZ$d ed <d!Z%d ed"<ejLd#$Gd%d&Z' d/d'Z(d0d(Z)d1d)Z*d*d*d+dddddd#d, d2d-Z+gd.Z,y)3uanu_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)AnyCallableFinalMappingSequence)check_gemini_evidence_fresh RESULT_FRESH)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 P/home/jay/workspace/.worktrees/task-2723-dev2/anu_v2/ci_gemini_watcher_runner.pyto_jsonzWatchResult.to_jsonhs!!$''N)returndict)__name__ __module__ __qualname____doc____annotations__rBrCrAr,r,HsQ"MNM M K(rCr,c(|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 책임 최소화). )r1head_sha)_has_active_trigger_for_head) schedulerr1rMs rAscheduler_backed_deduperPqs  1 1IPX 1 YYrCct|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)0123456789abcdefNrK).0cs rA z$_validate_hex_sha..s 811& & 8su+ 는 40-char hex SHA (hex chars only), got ) isinstancer-len ValueErrorlowerany)valuenamelowereds rA_validate_hex_shar`se eS !SZ2%5D6!XY^XabcckkmG 8 88D6!LUIVWW NrCct|jdxsgt|jdxsgt|jdxsgdS)u3triage_batch 결과에서 count 요약 dict 생성.applied dismissed escalated) applied_countdismissed_countescalated_count)rYget)outs rA_triage_count_summaryrjsPSWWY/526sww{39r:sww{39r: rCunknown) ownerrepotask_id owner_proofdedupe_checkerrecord_triggertriage audit_writerr;c  tddddddd d> fd} ttrttsdkrt dt d }| t td Sd }|r't|jjnd}||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| t.||||d(&S| t,||||d)|d*&S|'|jd+r| t t0|||d,-St|xrRt|jd.xr6t|jd/xst|jd0} | s| t2t4|||d1-S| ||nd}!|!r | t2t6|||d2d3|ddd4-St8||d5d5ddt:t<d5d6 }" t?|"|7| | || t2tF||||"d:d3|ddd;|j"d< =Scc}w#t@$r:}#| t t|||d8|#jBd9|#jD-cYd}#~#Sd}#~#wwxYw)?uFCI + 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 참조). 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 형식 오류. rkUNKNOWNN)r/r3r4r5r7r8r<r3cX|tvs Jd|dt|| |||||d| S)u=내부 WatchResult 생성 헬퍼. github_writes 는 항상 0.z terminal z not in ALL_TERMINALSr) r.r/r1r2r3r4r5r7r8r9r;r<)r r,) r.r/r3r4r5r7r8r<r;r2r1s rA_makezrun_watch_cycle.._makesS=(WIh\AV*WW(-'#-)'  rCru1pr_number 은 양의 정수여야 합니다, got r2u-gh_runner 이 None — capability gate 차단)r/r<)r1z actual HEAD (z...) != expected HEAD (u...) — stale head)r3r< diff_pathsudiff 에 scope 외 경로 u 건 포함: z... ci_rollupstateFAILURE remediableFu4CI FAILURE (non-remediable) — 자동 복구 불가)r3r4r<cd||S)Nreviews)methodpathrK)rr gh_runners rAz!run_watch_cycle..sYydKrC)r1current_head_sha github_apirmrnfindingscy)NrK)recs rArz!run_watch_cycle..1srC)rtrordztriage escalated u건 — LOOP_BOUNDARY)r3r4r5r7r<SUCCESSu3triage clean + CI SUCCESS → MERGE_READY_CANDIDATEutriage clean 이지만 CI=u — 보수적 LOOP_BOUNDARYself_keyu8owner_proof.self_key=True — self Gemini trigger 차단)r/r3r4r5r<is_owneradminpushuAowner proof 없음/불충분 — GEMINI_EXTERNAL_TRIGGER_REQUIREDz(pr=z, head=u#...) 이미 trigger 됨 — DEDUPEDT) schemaropr 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=)r/r3r4r5r8r<)r.r-r/r-r3r-r4r-r5r-r7r6r8r6r<r-rDr,)$r)rXr0r:rZr`rr-r[striprsetrrYrhrr statusr r triage_batchrjrrr'rr%r$r r rr rcodemessager")$r1r2expected_filesrrmrnrorprqrrrsrtr;rxexpected_head_normactual_head_rawr3rzexpected_files_setp out_of_scopecir4 _github_apifrr5r_triage _audit_writer triage_outsummary unresolvedralready_triggereddecisionexcs$`` ` ` rArun_watch_cyclers7\!-! )&*%)         $ #    : i %It)D UVLYMZ[[*=/J *)B   CO;J#o&,,.446rK(( $# 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[!_typingrrrrr(anu_v2.gemini_evidence_freshness_checkerr r anu_v2.owner_trigger_decisionr r r rranu_v2.auto_gemini_triageranu_v2.executor_schedulerrrrJrrrrrr frozensetr r"r$r%r'r) dataclassr,rPr`rjr__all__rKrCrArs #::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(&,08<8<&*?CZZZ" Z " Z  Z ZZ*Z6Z6Z $Z=ZZZB  rC