jT UdZddlmZddlZddlZddlZddlmZmZddl m Z ddl m Z ddl mZmZmZddlmZd Zd ed <d Zd ed <GddeZGdde ZehdZded<ehdZded<ehdZded<ehdZded< dPdZdQdZ dRdZ dQdZ!ed Gd!d"Z"dSd#Z#dSd$Z$dTd%Z%dSd&Z&dd' dUd(Z'ejPjRd)ejTjRd*ejVjRd+ejXjRd,ejZjRd-ej\jRd.iZ/d/ed0<d1Z0d ed2< dd3 dVd4Z1d5Z2d ed6< dd7 dWd8Z3e d9Z4d:ed;< dXdd3 dYd<Z5d=Z6d>ed?< ed Gd@dAZ7dZdBZ8 d[dCZ9ddD d\dEZ:ed GdFdGZ;d]dHZ<ed GdIdJZ=d^dKZ>d_dLZ?d`dMZ@dadNZAgdOZBy)bu@anu_v2.second_review_recovery — GEMINI_SECOND_REVIEW_BOTTLENECK 자동 복구 모듈 (task-2565). follow-up commit 이후 Gemini evidence 가 old head 에만 존재하고 current head 에는 없어 CI gate 가 SHA mismatch 로 실패하는 병목을 코드/파일 자동화로 고정한다. 9 상태 enum (SecondReviewState): FOLLOW_UP_COMMIT_CREATED → GEMINI_EVIDENCE_STALE_ON_HEAD → SECOND_REVIEW_PENDING → SECOND_REVIEW_TRIGGER_REQUIRED → SECOND_REVIEW_OWNER_TRIGGER_POSTED → SECOND_REVIEW_FRESH_DETECTED → CI_RERUN_REQUIRED_AFTER_FRESH → MERGE_READY_AFTER_SECOND_REVIEW (timeout 분기: SECOND_REVIEW_TIMEOUT) schema 버전: second_review_decision.v1 (상수: SECOND_REVIEW_DECISION_SCHEMA) pre_merge_commit_decision.v1 (상수: PRE_MERGE_COMMIT_DECISION_SCHEMA) 불변 원칙 (task-2565 §8): - manual_owner_input_requested 항상 False — 회장 수동 요청 금지 doctrine - long_polling_used 항상 False — long polling 금지 (task-2556 §9) one-way isolation: anu_v2/ 외부 import 금지. stdlib + enum + json + pathlib 만 사용. ) annotationsN) dataclassfield)Enum)Path)AnyCallableFinal)SECOND_REVIEW_GRACE_SECONDSz anu_v2.second_review_decision.v1z Final[str]SECOND_REVIEW_DECISION_SCHEMAz#anu_v2.pre_merge_commit_decision.v1 PRE_MERGE_COMMIT_DECISION_SCHEMAceZdZdZy)SchemaViolationu_schema 검증 실패 — 필수 필드 누락, 잘못된 enum 값, 또는 불변 원칙 위반.N)__name__ __module__ __qualname____doc__?/home/jay/workspace/scripts/../anu_v2/second_review_recovery.pyrr0sirrc4eZdZdZdZdZdZdZdZdZ dZ d Z d Z y ) SecondReviewStateuGEMINI_SECOND_REVIEW_BOTTLENECK 자동화 상태 머신 9 상태 (task-2565 §2). 전이 순서: FOLLOW_UP_COMMIT_CREATED → GEMINI_EVIDENCE_STALE_ON_HEAD → SECOND_REVIEW_PENDING → SECOND_REVIEW_TRIGGER_REQUIRED → SECOND_REVIEW_OWNER_TRIGGER_POSTED → SECOND_REVIEW_FRESH_DETECTED → CI_RERUN_REQUIRED_AFTER_FRESH → MERGE_READY_AFTER_SECOND_REVIEW (timeout 분기: → SECOND_REVIEW_TIMEOUT) FOLLOW_UP_COMMIT_CREATEDGEMINI_EVIDENCE_STALE_ON_HEADSECOND_REVIEW_PENDINGSECOND_REVIEW_TRIGGER_REQUIRED"SECOND_REVIEW_OWNER_TRIGGER_POSTEDSECOND_REVIEW_FRESH_DETECTEDSECOND_REVIEW_TIMEOUTCI_RERUN_REQUIRED_AFTER_FRESHMERGE_READY_AFTER_SECOND_REVIEWN) rrrrrrrrrrrr r!rrrrr6s?  :$C!3%E")M&#A 3$C!&G#rr>NONEOUTDATED_THREAD_ON_OLD_HEAD#GEMINI_EVIDENCE_NOT_ON_CURRENT_HEAD#SHA_MISMATCH_AFTER_FOLLOW_UP_COMMITzFinal[frozenset[str]]_VALID_STALE_REASON>r" SHA_MISMATCHGEMINI_EVIDENCE_STALE_VALID_CI_GATE_REASON>TIMEOUTWAITING ESCALATED MERGE_READYFRESH_DETECTED_VALID_FINAL_DECISION>code_fixtest_fix report_onlyevidence_required_VALID_CHANGE_TYPEc nidtd|d|d|d|d|d|d|d |d |d | d d dd d| d| d| S)u``second_review_decision.v1`` schema dict 를 생성한다 (task-2565 §4.1). 박제 필드 (절대 변경 금지): - ``manual_owner_input_requested``: 항상 False (회장 수동 요청 금지 doctrine) - ``long_polling_used``: 항상 False (long polling 금지) - ``schema``: SECOND_REVIEW_DECISION_SCHEMA Args: task_id: 관련 task ID (예: "task-2565"). pr_number: PR 번호. old_head_sha: follow-up commit 이전 head SHA. current_head_sha: 현재 head SHA. latest_gemini_commit_id: 최신 Gemini review commit_id. gemini_fresh_on_current_head: current head 기준 fresh evidence 존재 여부. stale_reason: stale 판정 이유 (허용 값: _VALID_STALE_REASON). ci_gate_reason: CI gate 실패 이유 (허용 값: _VALID_CI_GATE_REASON). owner_trigger_required: owner_trigger_only 자동 호출 필요 여부. owner_trigger_result: "POSTED" | "DEDUPED" | "FAILED" | "NONE". fresh_detected_at: fresh evidence 감지 ISO timestamp 또는 None. ci_rerun_required: CI rerun 필요 여부. final_decision: 최종 결정 (허용 값: _VALID_FINAL_DECISION). Returns: 검증되지 않은 decision dict (validate_second_review_decision 으로 후속 검증 권장). schematask_id pr_number old_head_shacurrent_head_shalatest_gemini_commit_idgemini_fresh_on_current_head stale_reasonci_gate_reasonowner_trigger_requiredowner_trigger_resultmanual_owner_input_requestedFlong_polling_usedfresh_detected_atci_rerun_requiredfinal_decision)r ) r7r8r9r:r;r<r=r>r?r@rCrDrEs rbuild_second_review_decisionrFqsR / 7  Y     ,   "#:   '(D     .  !"8   4  '  U  .  .  .! rchd}|t|jz }|rtdt||dtk7rtdtd|d|ddur td|d dur td |d t vr!td |d d tt |dt vr!td|dd tt |dtvr!td|dd tty)u``second_review_decision.v1`` schema 검증 (task-2565 §4.1). 검증 항목: 1. schema 일치 2. manual_owner_input_requested 항상 False 3. long_polling_used 항상 False 4. 필수 필드 전수 존재 5. stale_reason, ci_gate_reason, final_decision enum 허용 값 Args: decision: build_second_review_decision 으로 생성된 dict. Raises: SchemaViolation: 위반 항목 발견 시. >r6r7r8r9r=r>rEr:rDrCrBr@r?r;r<rAu&second_review_decision 누락 필드: r6schema 불일치: expected=, got=rAFummanual_owner_input_requested must always be False — 회장 수동 요청 금지 doctrine (task-2565 §8 #1)rBu`long_polling_used must always be False — long polling 금지 (task-2556 §9, task-2565 §8 #4)r=u stale_reason 허용 값 위반:  not in r>u"ci_gate_reason 허용 값 위반: rEu"final_decision 허용 값 위반: N)setkeysrsortedr r&r)r/decision_required_fieldsmissings rvalidate_second_review_decisionrRs X]]_!55G4VG_4E F  ::)*G)JKH%( *  ./u< J  #$E1 H  '::.x/G.JK012 4   !)>>0:J1K0NO234 6   !)>>0:J1K0NO234 6  ?rct|||||dS)u6``pre_merge_commit_decision.v1`` schema dict 를 생성한다 (task-2565 §4.2). Args: merge_ready: MERGE_READY 5+1 조건 충족 여부. changed_files: 변경 파일 목록. change_type: 변경 유형 (허용: "report_only","code_fix","test_fix","evidence_required"). pre_merge_commit_allowed: merge 전 commit 허용 여부. redirect_to_post_merge_evidence: post-merge evidence redirect 활성화 여부. Returns: 검증되지 않은 decision dict (validate_pre_merge_commit_decision 으로 후속 검증 권장). r6 merge_ready changed_files change_typepre_merge_commit_allowedredirect_to_post_merge_evidence)r )rUrVrWrXrYs rbuild_pre_merge_commit_decisionrZs *3"&"$<+J  rchd}|t|jz }|rtdt||dtk7rtdtd|d|dt vr!td|ddtt y ) uF``pre_merge_commit_decision.v1`` schema 검증 (task-2565 §4.2). 검증 항목: 1. schema 일치 2. 필수 필드 전수 존재 3. change_type 허용 값 Args: decision: build_pre_merge_commit_decision 으로 생성된 dict. Raises: SchemaViolation: 위반 항목 발견 시. >r6rWrUrVrXrYu)pre_merge_commit_decision 누락 필드: r6rHrIrWuchange_type 허용 값 위반: rJN)rKrLrrMr r4rNs r"validate_pre_merge_commit_decisionr\sX]]_!55G7w7H I  ==)*J)MNH%( *   &88-h}.E-HI/01 3  9rT)frozenczeZdZUdZded<ded<ded<ded<ded <ded <d ed <d ed <ded<dZded<y)SecondReviewInputusecond-review 판정 입력 (caller가 채워서 주입). Attributes: task_id: 관련 task ID (예: "task-2565"). pr_number: PR 번호. old_head_sha: follow-up commit 이전 head SHA. current_head_sha: 현재 head SHA. latest_gemini_commit_id: 최신 Gemini review commit_id (없으면 None). ci_gate_failure_reason: CI gate 실패 이유 — "GEMINI_EVIDENCE_STALE" | "SHA_MISMATCH" | None. unresolved_thread_outdated: unresolved thread가 old head 기준 OUTDATED인지. follow_up_commit_detected: follow-up commit 감지 여부. elapsed_since_follow_up_seconds: follow-up 발생 후 경과 (caller 계산). owner_trigger_audit_entries: 기존 audit entries (dedupe 검사용). strr7intr8r9r: str | Noner;ci_gate_failure_reasonboolunresolved_thread_outdatedfollow_up_commit_detectedelapsed_since_follow_up_secondsrztuple[dict, ...]owner_trigger_audit_entriesN)rrrr__annotations__rhrrrr_r_FsI LN''&& $$##%((46!16rr_c|jxr|j|jk7}t|jxr|j|jk7}|j dv}|j }t|xr |xr|xr|S)u4조건 모두 충족 시 True — Gemini evidence가 follow-up commit 이후 stale 상태임을 판정. 4조건: 1. follow-up commit 감지 + head SHA 변경 2. latest_gemini_commit_id 존재 + current head에 없음 3. CI gate 실패 이유가 GEMINI_EVIDENCE_STALE 또는 SHA_MISMATCH 4. unresolved thread가 old head 기준 OUTDATED Args: inp: SecondReviewInput 판정 입력. Returns: 4조건 모두 True면 True, 하나라도 False면 False. )r(r')rfr:r9rdr;rcreinpcond1cond2cond3cond4s r&is_gemini_stale_on_head_after_followuprqcs  ) ) Vc.B.BcFVFV.VE ,, - e#2M2MQTQeQe2eE  & &*S SE  * *E 3%3E3e 44rc(|jtk\S)ufollow-up commit 이후 grace period가 경과했는지 판정. Args: inp: SecondReviewInput 판정 입력. Returns: elapsed_since_follow_up_seconds >= SECOND_REVIEW_GRACE_SECONDS 이면 True. )rgr rls rgrace_period_elapsedrtys  . .2M MMrc|jrt|stjSt|r+t |rtj Stj StjS)u상태 전이 결정 함수 — SecondReviewInput을 받아 현재 상태를 결정. 전이 우선순위: 1. follow_up_commit만 감지 → FOLLOW_UP_COMMIT_CREATED 2. 4조건 True + grace 경과 → SECOND_REVIEW_TRIGGER_REQUIRED 3. 4조건 True + grace 미경과 → SECOND_REVIEW_PENDING 4. 4조건 True → GEMINI_EVIDENCE_STALE_ON_HEAD (grace 로직은 2/3에서 처리) Args: inp: SecondReviewInput 판정 입력. Returns: SecondReviewState enum 값. )rfrqrrrtrrrrss rdetermine_statervsZ  $$-STW-X 999.c2  $$CC C$:: :  : ::rc:|jd|j}|jD]q}|jdxs|jdxsdd|jdxs|jdxsd}||k(s\|jddk(sqy y ) u=same-head dedupe 판정 — 동일 (pr_number, current_head_sha) POSTED 이미 존재하는지 확인. dedupe_key 포맷: "{pr_number}+{current_head_sha}" Args: inp: SecondReviewInput 판정 입력. Returns: 동일 dedupe key로 result=POSTED 항목이 audit_entries에 있으면 True. +r8prhead_shaheadresultPOSTEDTF)r8r:rhget)rl dedupe_keyentry entry_keys ris_owner_trigger_dedupedrsMM?!C$8$8#9:J00yy-F4FBGqS]I^IybgbkbklrbsIywyHz{  "uyy':h'F r)trigger_callablec|jd|j}t|sdd|ddSt|sdd|d|jdt d dSt |r"dd |d |jd |jd dS|dd|ddS ||j|jdd|d|jd |jddS#t$r*}dd|dt|jd|dcYd}~Sd}~wwxYw)u owner trigger 자동 호출 진입점 (4조건 + grace + dedupe 확인 후 호출). 흐름: 1. 4조건 미충족 → CONDITIONS_NOT_MET 2. grace 미경과 → GRACE_PENDING 3. dedupe True → DEDUPED 4. trigger_callable None → NOT_TRIGGERED (테스트용) 5. trigger_callable 호출 → POSTED (성공) / FAILED (예외) Args: inp: SecondReviewInput 판정 입력. trigger_callable: (pr_number, head_sha) → dict 형태의 호출 가능 객체. None이면 NOT_TRIGGERED 반환 (테스트/dry-run용). Returns: dict with keys: - triggered: bool - result: "POSTED"|"DEDUPED"|"FAILED"|"NOT_TRIGGERED"|"GRACE_PENDING"|"CONDITIONS_NOT_MET" - dedupe_key: str - reason: str rxFCONDITIONS_NOT_METu)4조건 미충족 — stale 상태 아님) triggeredr}rreason GRACE_PENDINGugrace period 미경과 — zs < sDEDUPEDu 동일 (pr=z, head=u) POSTED 이미 존재N NOT_TRIGGEREDu(trigger_callable=None — dry-run 모드Tr~u owner trigger 호출 성공 (pr=)FAILEDutrigger_callable 예외: : ) r8r:rqrtrgr r Exceptiontyper)rlrrexcs rauto_trigger_owner_reviewrs_4MM?!C$8$8#9:J 2# 6*$A     $%$-667tC C>C93C>9C>z-task-2565.gemini-stale-on-head-after-followupz/task-2565.second-review-owner-trigger-requestedz,task-2565.second-review-owner-trigger-postedz&task-2565.second-review-fresh-detectedztask-2565.ci-rerun-after-freshz)task-2565.merge-ready-after-second-reviewzFinal[dict[str, str]]_STATE_MARKER_MAPz%task-2565.second-review-decision.jsonSECOND_REVIEW_DECISION_JSON marker_dircvg}thd}|t|jz }|rtdt |dt j |j}|rt||}|j|||jd|} tt| |}|j||S)u상태별 marker 파일 생성 + second-review-decision.json 갱신. 상태 → marker 파일 매핑: GEMINI_EVIDENCE_STALE_ON_HEAD → task-2565.gemini-stale-on-head-after-followup SECOND_REVIEW_TRIGGER_REQUIRED → task-2565.second-review-owner-trigger-requested SECOND_REVIEW_OWNER_TRIGGER_POSTED → task-2565.second-review-owner-trigger-posted SECOND_REVIEW_FRESH_DETECTED → task-2565.second-review-fresh-detected CI_RERUN_REQUIRED_AFTER_FRESH → task-2565.ci-rerun-after-fresh MERGE_READY_AFTER_SECOND_REVIEW → task-2565.merge-ready-after-second-review 또한 항상 task-2565.second-review-decision.json 갱신. Args: task_id: 관련 task ID. state: 현재 SecondReviewState. decision: auto_trigger_owner_review 반환 dict 또는 임의 decision dict. marker_dir: marker 저장 디렉토리. None이면 MARKER_DIR 사용. Returns: 생성/갱신된 marker 경로 list. >r6r8r9r=r>rEr:rDrCrBr@r?r;r<rAu,emit_phase2_markers: decision 누락 필드 uR — build_second_review_decision()의 완전한 결과를 전달해야 합니다.r)r7state)payloadr) frozensetrKrL ValueErrorrMrrvalue write_markerappendr) r7rrOrcreated_SCHEMA_V1_REQUIREDmissing_fields marker_namepdecision_payloads remit_phase2_markersr!s8G +45+)3x}}+??N:6.;Q:RS\ \  $'' 4K  <q( ( 0:JWabA NN1 Nrz&memory/audit/owner_trigger_audit.jsonl_DEFAULT_AUDIT_REL_PATH) audit_pathc  ddl}ddl}||nt t j }|jjddt|dd5}|j|j|j |jtj|d d d z|j!|j"|j|j|j|j$ ddd|j S#t$r}td|d}~wwxYw#|j|j|j$wxYw#1swY|j SxYw) uowner_trigger audit JSONL에 한 줄 atomic append. 기본 경로: memory/audit/owner_trigger_audit.jsonl entry는 dict (timestamp, pr_number, head_sha, result, source 등 포함 권장). Args: entry: audit 기록 dict. timestamp/pr_number/head_sha/result/source 포함 권장. audit_path: JSONL 파일 경로. None이면 기본 경로 사용. Returns: audit 파일 절대 경로. Raises: OSError: 디렉토리 생성 또는 파일 기록 실패 시. rNzappend_owner_trigger_audit requires POSIX fcntl (Linux only). ANU CI is Linux self-hosted; non-Linux environments not supported.Tparentsexist_okautf-8)encodingF) ensure_ascii sort_keys )fcntl ImportErrorNotImplementedErrorosrrresolveparentmkdiropenflockfilenoLOCK_EXwritejsondumpsflushfsyncLOCK_UN)rrrertargetfhs rappend_owner_trigger_auditris2. &2j=T8U ^ ^ `F MMt4 fcG ,4 BIIK/ 4 HHTZZETJTQ R HHJ BHHRYY[ ! KK U]] 34 >> ' ! Q  " KK U]] 34 >> s<D+E+AD<*E+ D9( D44D9<,E((E++Fz memory/eventsz Final[Path] MARKER_DIRc||ntj}|jdd||z }|jdr||ni}t j |dd}t jd|d |d d dd }t|j} |5|j||jtj|jdddtj|||jS|j%d|jS#1swYQxYw#t $r|j#d wxYw)umarker 파일을 생성하고 절대 경로를 반환한다. Args: marker_name: marker 파일 이름. ``.json`` 으로 끝나면 payload 를 JSON 으로 기록. 그 외이면 빈 파일 touch (payload 무시). payload: JSON marker 일 때 기록할 dict. None 이면 {} 로 기록. marker_dir: marker 저장 디렉토리. None 이면 ``MARKER_DIR`` 사용. Returns: 생성된 marker 파일의 절대 경로. Raises: OSError: 디렉토리 생성 또는 파일 기록 실패 시. NTrz.jsonF)rindentw.z.tmpr)dirprefixsuffixdeleter) missing_ok)r)rrrendswithrrtempfileNamedTemporaryFilernamerrrrrreplacerunlinktouch) rrr target_dir marker_pathdata serializedtftmp_paths rrrsD*!+ 6*JOOQJTD1{*KG$!-w2ZZ5C  ( ( {m1%  =  &$ % & JJx -      4(      & &   OOtO ,  s%D8AD,D8,D51D88Ez Final[int]MAX_CI_RERUN_PER_HEADcjeZdZUdZded<ded<ded<ded<ded <ded <d Zd ed <dZded<y) CIRerunInputuCI rerun 자동 판정 입력 (caller가 채워서 주입). Attributes: pr_number: PR 번호. current_head_sha: 현재 head SHA. gemini_fresh_on_current_head: 최신 review commit_id == current head 여부. ci_gate_failed_with_stale_reason: failure_reason이 EVIDENCE_STALE 또는 SHA_MISMATCH인지. current_head_unchanged_since_failure: CI 실패 이후 head SHA 변경 없음 여부. unresolved_thread_count: 미해결 thread 수 (0 = 허용, >0 = triage 별도 판정). failed_job_identifiers: 실패한 CI job 식별자 목록. previous_rerun_attempts: 같은 (head_sha, job_id) 누적 rerun 횟수. rar8r`r:rdr< ci_gate_failed_with_stale_reason$current_head_unchanged_since_failureunresolved_thread_countrtuple[str, ...]failed_job_identifiersrprevious_rerun_attemptsN)rrrrrirrrrrrrsB N"&&&***..  .0O0#$S$rrc|jtk\ry|j}|j}|j}|j dk(}t |xr |xr|xr|S)uCI rerun 4조건 + cap 미초과 여부 판정 (task-2565 §5 Phase 3.1). 4조건 (모두 충족 + cap 미초과 시 True): 1. gemini_fresh_on_current_head: Gemini fresh evidence가 current head에 존재 2. ci_gate_failed_with_stale_reason: stale reason으로 실패한 CI gate 존재 3. current_head_unchanged_since_failure: CI 실패 이후 head 변경 없음 4. unresolved_thread_count == 0: 미해결 thread 없음 추가 cap: previous_rerun_attempts >= MAX_CI_RERUN_PER_HEAD(=3) 시 False. Args: inp: CIRerunInput 판정 입력. Returns: 4조건 모두 충족 + cap 미초과 시 True, 하나라도 불충족 시 False. Fr)rrr<rrrrdrks rshould_rerun_failed_ci_jobsrsa$ ""&;;  , ,E  0 0E  4 4E  ' '1 ,E 3%3E3e 44rc *d||t||||ddS)u(``anu_v2.ci_rerun_decision.v1`` schema dict 생성 (task-2565 §5 Phase 3). 박제 필드: - ``schema``: "anu_v2.ci_rerun_decision.v1" - ``long_polling_used``: 항상 False (long polling 금지 박제) Args: pr_number: PR 번호. current_head_sha: 현재 head SHA. failed_jobs: rerun 대상 CI job 식별자 목록. rerun_allowed: rerun 허용 여부. reason: 허용/차단 이유 문자열. attempt_number: 이번 rerun 시도 번호. Returns: ci_rerun_decision.v1 schema dict. zanu_v2.ci_rerun_decision.v1F)r6r8r: failed_jobs rerun_allowedrattempt_numberrB)listr8r:rrrrs rbuild_ci_rerun_decisionrs+60,K(&("  r)rerun_callablec |jdz}|jtk\rLt|j|j|j dd|jdt|}d|d|dSt |sr|jsd }n.|jsd }n|jsd }nd |jd }t|j|j|j d||}d||dS|8t|j|j|j dd|}d|d|dS ||j|j t|j|j|j dd|jd|d|}d|d|dS#t$rZ}dt|jd|}t|j|j|j d||}d||dcYd}~Sd}~wwxYw)uCI rerun 자동 호출 진입점 (adapter pattern, task-2565 §5 Phase 3). 흐름: 1. should_rerun_failed_ci_jobs(inp) 호출 2. cap 초과 → result="CAP_EXCEEDED" 3. 조건 미충족 (cap 미초과) → result="SKIPPED" 4. 조건 충족 + rerun_callable=None → result="DECISION_ONLY" 5. 조건 충족 + rerun_callable 있음 → 호출 후 result="POSTED" 또는 "FAILED" Args: inp: CIRerunInput 판정 입력. rerun_callable: (pr_number, failed_jobs) → dict 형태 callable. None이면 DECISION_ONLY 반환 (dry-run 모드). Returns: dict with keys: result (str), reason (str), decision (dict) Fu0CI rerun cap 초과 — previous_rerun_attempts=z >= r CAP_EXCEEDEDr)r}rrOu3Gemini fresh evidence 미존재 — rerun 건너뜀u9CI gate 실패가 stale reason 아님 — rerun 건너뜀u3CI 실패 이후 head 변경됨 — rerun 건너뜀uunresolved thread 존재 (u개) — rerun 건너뜀SKIPPEDNTu?CI rerun 조건 충족 — dry-run 모드 (rerun_callable=None) DECISION_ONLYuCI rerun 호출 성공 (pr=z , attempt=rr~urerun_callable 예외: rr)rrrr8r:rrr<rrrrrr)rlrrrOrrs rauto_rerun_failed_ci_jobsr7s?,0014N ""&;;*mm 1122EcFaFaEbbfg|f}~)  %x(    's +//JF55PF99JF1#2M2M1NNfgF*mm 1122)      *mm 1122T)  &x(    s}}c&@&@A*mm 11220z.IYYZ[)  x(    *49+=+=*>bF*mm 1122)      s 'A%F G0AG+%G0+G0cNeZdZUdZded<ded<ded<ded<ded <ded <y ) MergeReadyInputuMERGE_READY 6조건 판정 입력 (task-2565 §5 Phase 3.2, context.md §7.5). Attributes: ci_all_green: CI 11/11 SUCCESS 여부. gemini_fresh_on_current_head: latest review commit_id == current head 여부. unresolved_thread_count: 미해결 thread 수. merge_state_status: mergeStateStatus 값 ("CLEAN" | "BEHIND" | "BLOCKED" | ...). effective_diff_matches_expected_files: effective diff == expected_files 여부. forbidden_path_count: forbidden path 위반 파일 수 (0 = 허용). rd ci_all_greenr<rarr`merge_state_status%effective_diff_matches_expected_filesforbidden_path_countNrrrrrirrrrrs- "&&  +//rrct|jxrM|jxr?|jdk(xr.|jdk(xr|j xr|j dk(S)uMERGE_READY 6조건 전수 충족 여부 판정 (task-2565 §3.2 + context.md §7.5). 6조건 (모두 충족 시 True): 1. ci_all_green: CI 11/11 SUCCESS 2. gemini_fresh_on_current_head: Gemini fresh evidence on current head 3. unresolved_thread_count == 0: 미해결 thread 없음 4. merge_state_status == "CLEAN": mergeStateStatus CLEAN 5. effective_diff_matches_expected_files: effective diff == expected_files 6. forbidden_path_count == 0: forbidden path 위반 없음 Args: inp: MergeReadyInput 판정 입력. Returns: 6조건 모두 True면 True, 하나라도 False면 False. rCLEAN)rdrr<rrrrrss ris_merge_readyrsu"   *  , , *  ' '1 , *  " "g - *  5 5  *  $ $ )  rc:eZdZUdZded<ded<ded<ded<y ) PreMergeCommitInputupre-merge commit 차단 판정 입력 (task-2565 §5 Phase 3.2). Attributes: merge_ready: MERGE_READY 6조건 충족 여부. changed_files: 변경 파일 경로 목록. commit_message_hint: commit message prefix 힌트 ("report:", "qc:", "lifecycle:", "evidence:", ...). only_touches_report_files: 변경 파일이 비기능 영역(memory/reports/, memory/events/)만인지. rdrUrrVr`commit_message_hintonly_touches_report_filesNrrrrrrs!""##rrc|jjj}|jr#|j ds|j dry|j dry|j Dcgc]*}|j ds|j drd|vr|,}}|r"t |t |j k(ry|j dry |jry|j Dcgc]}d |vs d |vsd |vs|}}|j Dcgc]}|jd r||vr|}}|r|sy|ryy cc}wcc}wcc}w)ucommit 변경 유형 5종 중 매칭 결정 (내부 헬퍼). 5종 wording 패턴: 1. "report wording only" — only_touches_report_files & hint starts with "report" 2. "QC Verdict wording" — hint starts with "qc" 3. "lifecycle marker wording" — only_touches lifecycle marker dir 4. "non-functional summary" — only_touches_report_files & generic 5. "evidence text 보강" — hint starts with "evidence" 내부적으로 matched change_type을 결정: - report_only: 1, 4 - report_only (qc): 2 - report_only (lifecycle): 3 - evidence_required: 5 - code_fix: 코드/테스트 변경 포함 - test_fix: 테스트만 변경 reportzreport:r2qczmemory/events/zmemory/z /lifecycle/evidencer3test_z_test.z/tests/z.pyr1r0)rlowerstripr startswithrVlenr)rlhintflifecycle_files test_files code_filess r_detect_change_typerse$  " " ( ( * 0 0 2D $$$//(*CtW`Ga t $$ <<( )all9.E-[\J\ O3/3s7H7H3II z"" $$!..b'Q,(a-S\`aSa!bJb$$ ::e *!4 J * 9 cs8/E :E E Ec\t|}|js|dfS|dk(ry|dvr|dfS|dfS)upre-merge commit 유형 분류 + 허용 여부 결정 (task-2565 §5 Phase 3.2). 반환 규칙: - merge_ready=True + 비기능 wording 패턴 → ("report_only", False) — 차단 - merge_ready=True + 코드/테스트 변경 포함 → ("code_fix" | "test_fix", True) — 허용 - merge_ready=False → (change_type, True) — 허용 (merge_ready 아직 아니면 차단 불필요) Args: inp: PreMergeCommitInput 판정 입력. Returns: (change_type, pre_merge_commit_allowed) 튜플. Tr2)r2F)r0r1)rrU)rlrWs rclassify_pre_merge_commitr-sN&c*K ??T""m#%..T""  rct|\}}t|jxr |dk(xr| }t|jt |j |||dS)u>pre-merge commit 차단 decision dict 생성 (task-2565 §5 Phase 3.2). schema: PRE_MERGE_COMMIT_DECISION_SCHEMA merge_ready=True + report_only 시 redirect_to_post_merge_evidence=True. Args: inp: PreMergeCommitInput 판정 입력. Returns: pre_merge_commit_decision.v1 schema dict. r2rT)rrdrUr rrV)rlrWallowedredirects rbuild_pre_merge_block_decisionrNs_5S9KCOOT }(DTWUH3c//0"$++3  rc|jdd}|jdg}|Dcgc] }d|vsd|vs |}}|rd}n#|dk(r|Dcgc] }d|vs| }}|rd }nd }nd }|t||d Scc}wcc}w) u차단된 pre-merge commit decision → post-merge marker용 payload 생성 (task-2565 §5 Phase 3). 차단된 report_only commit을 post-merge 단계로 redirect하기 위한 payload. redirect_to 결정: - change_type="report_only" + original hint 기반: - "lifecycle marker"가 changed_files에 있으면 "lifecycle marker" - 그 외 "post-merge smoke" 또는 "reconcile evidence" Args: blocked_decision: build_pre_merge_block_decision 반환 dict. Returns: dict with keys: - original_change_type: str - original_changed_files: list[str] - redirect_to: "post-merge smoke" | "reconcile evidence" | "lifecycle marker" rWrzrV lifecycleeventszlifecycle markerr2reportszreconcile evidencezpost-merge smoke)original_change_typeoriginal_changed_files redirect_to)rr)blocked_decisionrWrVrrr# report_filess r$post_merge_evidence_redirect_payloadr&js&#&&}b9K$(("=M#0UQ;!3CxST}qUOU(  %#0CaINC C .K,K( !,"&}"5" V Ds A4A4 A9A9)r r rrrrFrRrZr\rr_rqrtrvrrrrrrrrrrrrrrrr&)r7r`r8rar9r`r:r`r;r`r<rdr=r`r>r`r?rdr@r`rCrbrDrdrEr`returndict[str, Any])rOr(r'None) rUrdrVz list[str]rWr`rXrdrYrdr'r()rlr_r'rd)rlr_r'r)rlr_rz!Callable[[int, str], dict] | Noner'dict) r7r`rrrOr*r Path | Noner'z list[Path])rr*rr+r'r)N)rr`rzdict[str, Any] | Nonerr+r'r)rlrr'rd)r8rar:r`rrrrdrr`rrar'r()rlrrz-Callable[[int, tuple[str, ...]], dict] | Noner'r()rlrr'rd)rlrr'r`)rlrr'ztuple[str, bool])rlrr'r()r$r(r'r()Cr __future__rrrr dataclassesrrenumrpathlibrtypingrr r anu_v2.polling_policyr r rir rrrrr&r)r/r4rFrRrZr\r_rqrtrvrrrrrrrr r!rrrrrrrrrrrrrrrrrrr&__all__rrrr3sZ.# ('' > -OzN/T *T jjj HH8.78.*09:0, 09:0,-67-): :: :  : ! :#':::!::"::::zH Z  #  &* <' Z $77785, N;<,;?R R 8R  R r3399744::988>>6228803399(55;;3 ,( +RZQG# ? ? ??  ?  ?H'ONC #, ,, ,b/ K/g &*2!# 2!2! "2! 2!  2!n%&z%c  $%%%05:###! #  #  ###REIp p Bp  p j $(: $ $ $ $ ;|B8(Z! r