nj[ UdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z ddlmZmZddlmZddlmZddlmZmZmZeej0j3d eeej9j:j:Zeej9j:j:Zeee j@vr"e j@jCdeedd l"m#Z#m$Z$m%Z%ejLe'Z(d Z)d Z*d Z+dZ,dddddddddddddZ-de.d<d>dZ/gdgdgdgdgd d!Z0d"e.d#<Gd$d%eeZ1e Gd&d'Z2ed(efZ3de)fd?d)Z4hd*Z5d@d+Z6e*fdAd,Z7ejpd-ejrZ:ejpd.ejvZdDd1Z?dEd2Z@de)d3 dFd4ZAd5dde)e*d6dd7 dGd8ZBdd9 dHd:ZCdIdJd;ZDdIdKd<ZEe'd=k(re jeEyy)Luutils/post_merge_smoke_runner.py — task-2512 5 모듈 #4. 회장 명시: 자동 머지 직후 origin/main 기준 smoke를 자동 실행하고, smoke 실패 시에만 Critical #7 (POST_MERGE_SMOKE_FAILED) escalation packet 생성. 산출물 = 코드 + 회귀 테스트. wiring(task-2514)/reporting(task-2513) 보류. automation_contracts.py(task-2509+2 freeze) 그대로 import: - SmokeResult, CriticalEscalationType, EscalationPacket - to_json ) annotationsN) dataclassasdict)datetimetimezone)Enum)Path)AnyCallableOptionalWORKSPACE_ROOT)CriticalEscalationTypeEscalationPacket SmokeResultiXiz ...[TRUNCATED {n} bytes]... 4486ea368)merge_commit_hintpr2cd8178b738334b09:59ec8d37>) task-2506 task-2507 task-2509 task-2511zdict[str, dict[str, Any]]REPLAY_FIXTURESc,tj|S)uMREPLAY_FIXTURES에서 task_id에 해당하는 fixture 반환. 없으면 None.)r get)task_ids 4/home/jay/workspace/utils/post_merge_smoke_runner.pyget_replay_fixturer%?s   w '')pytestz*tests/regression/test_critical_gap_2506.py-q)r'z*tests/regression/test_git_evidence_2507.pyr()r'z2tests/regression/test_merge_queue_executor_2509.pyr()r'z0tests/regression/test_auto_gemini_triage_2511.pyr()r'z5tests/regression/test_post_merge_smoke_runner_2512.pyr()rrrrz task-2512zdict[str, list[str]]SMOKE_COMMAND_REGISTRYc eZdZdZdZdZdZdZy) SmokeStatusPASSFAILSKIPPEDTIMEOUTBLOCKEDN)__name__ __module__ __qualname__r,r-r.r/r0r&r$r+r+Ps D DGGGr&r+ceZdZUdZded<ded<ded<ded<d ed <d ed <d ed<ded<d ed<d ed<ddZddZy)PostMergeSmokeRunuSmoke 실행 envelope. 회장 §6 정보량을 freeze contract 위반 없이 전달. Fields: merge_commit: 입력 SHA (origin/main HEAD와 일치 검증 후 보존) task_id: task spec에서 추출한 task_id status: SmokeStatus enum smoke_result: freeze contract `SmokeResult` (transport) duration_ms: subprocess 실행 시간(ms) smoke_command: 실제 실행한 command (None=정의 안됨) allow_continuation: PASS/SKIPPED 시 True. merge_queue 다음 단계 신호. escalation: FAIL/TIMEOUT/BLOCKED 시 EscalationPacket. 그 외 None. stale: merge_commit ≠ origin/main HEAD 시 True dry_run: 입력 dry_run 플래그 보존 str merge_commitr#r+statusr smoke_resultint duration_msOptional[list[str]] smoke_commandboolallow_continuationzOptional[EscalationPacket] escalationstaledry_runcvt|}t|jtr|jjn |j|d<|j b|d}t|j j tr |j j jn|j j |d<|S)Nr9rAescalation_type)r isinstancer9rvaluerArE)selfdescs r$to_dictzPostMergeSmokeRun.to_dictws 4L+5dkk4+Hdkk''dkk( ?? &L/Cdoo==tD//55__44 ! " r&cHtj|jSN)jsondumpsrK)rHs r$to_jsonzPostMergeSmokeRun.to_jsonszz$,,.))r&N)returndict)rQr7)r1r2r3__doc____annotations__rKrPr4r&r$r6r6\sL  L &&** K M *r&r6.cXtj||xsttdd|S)NT)cwdcapture_outputtexttimeout) subprocessrunr7 WORKSPACE)argsrVrYs r$_default_runnerr^s+ >>  !3y>   r&>-f--force --no-verify--force-with-leasect|}|Dcgc]}|tvs|dk(s|}}|rtd|d|vr tdd|vr tdycc}w)uIsmoke command에 force/admin/rebase/cherry-pick 등 금지 인자 차단.z--adminzFORBIDDEN_GIT_FLAGS detected: rebaseREBASE_FORBIDDENz cherry-pickCHERRY_PICK_FORBIDDENN)listFORBIDDEN_GIT_FLAGS RuntimeError)r]flatabads r$assert_no_forbidden_git_flagsrmsu :D Ia#66!y.1 IC I ;C5ABB4-..233 Js AAc |y|jdd}t|}||kr|S|tz}|d|}|| d}|d|zz }tj |}|j dd|z|j ddzS)uStext를 cap byte로 자른 결과 반환. 초과 시 head + truncate marker + tail.Nutf-8replace)errorsr)n)encodelenHEAD_TAIL_RATIOTRUNCATE_MARKER_FMTformatdecode) rXcapencodedrshalf head_bytes tail_bytes truncated_nmarkers r$capture_head_tailrs |kk')k4G G ACx / !D$J$Ja$h,K ' '+ ' 6F')4     GI  6 7r&z```yaml\s*\n(.*?)```z^# (task-\d+(?:\+\d+)?)cjtj|}|r|jdS|jS)N)_TASK_ID_HEADER_REsearchgroupstem) task_text task_filems r$extract_task_idrs+!!),A1771:. .r&cd}tj|}|r |jd}t|}|r|St jd|tj }|rW|jdj j d}|r'|jdvrtj|S|tvrtt|Sy)utask md 본문에서 smoke_command 추출. 우선순위: 1) yaml block 안 `smoke_command:` (list 또는 quoted scalar) 2) `smoke_command:` 단독 라인 (markdown 스칼라) 3) SMOKE_COMMAND_REGISTRY[task_id] 4) None (미정의) ror^smoke_command:\s*(.+)$`>nonenullN) _YAML_BLOCK_RErr_parse_smoke_command_in_yamlre MULTILINEstriplowershlexsplitr)rg)rr# yaml_blockrcmdline_mraws r$extract_smoke_commandrsJi(AWWQZ *:6 J YY19bll KF ll1o##%++C0 399;&66;;s# #((*7344 r&ctjd|tj}|rg}|jdj D]}|j }|j ds%|ddj }|j dr|jdr|dd}n'|j dr|jdr|dd}|j||r|SdStjd|tj}|rf|jdj j dj d}|r'|jdvrtj|Sy) Nz'^smoke_command:\s*\n((?:\s*-\s*.+\n?)+)r-"'r>rr) rrrr splitlinesr startswithendswithappendrrr)rlist_mitemslinesrscalar_ms r$rrs; YY2 F LLO..0 D A<<$AB%++-C~~c"s||C'8!Bi$c):!Bi LL  u'4'yy3ZNHnnQ%%'--c288= 399;&66;;s# # r&cJ |gdd|gdd}t|dddk7ry t|d d xsd j}|sy ||k(xs$|j|xs|j| S#t$r }tj d |Yd }~y d }~wwxYw)ugit fetch origin main → rev-parse origin/main과 merge_commit 비교. return True if origin/main HEAD가 merge_commit과 다름 (stale). runner 실패 시 stale=True 보수적 판정. )gitfetchoriginmain<rY)rz rev-parsez origin/main returncoderrTstdoutroz check_main_head_stale failed: %sN)getattrrr Exceptionloggerwarning)r8runnerrpheadexcs r$check_main_head_stalers 12> 7 D 2|Q '1 ,Hb)/R668L(jDOOL,Ij\MdMdeiMjkk 93?s"(A9!A9 +A99 B"BB")extra_evidence timeout_secc tjdtjd|dtjdi} gd} d} ||||j|j |j |j|j|tjtjjd } |r| j|t||t j"| j%|dd | | | S) u{POST_MERGE_SMOKE_FAILED escalation packet. 회장 명시 — Critical 7종 외 보고 금지. enum 정확 매칭. z,smoke command exited non-zero on origin/mainz smoke command exceeded timeout (zs)zPsmoke_command undefined and dry_run=False (auto merge requires smoke definition))3Re-run smoke locally on freshly fetched origin/mainz3Disable auto-merge for this task and route to chairz+Define smoke_command in task spec and retryr) r8r#r>r9 exit_code stdout_tail stderr_tailfailure_reasonr< timestampz smoke failureuPost-merge smoke against origin/main failed. Continuing auto-merge of subsequent PRs without human review violates 자동 머지 10조건 #10.)r# pr_numberrEreasonwhy_auto_cannot_continue safe_optionsrecommended_optionevidence)r+r-r/r0rGrrrrrnowrutc isoformatupdaterrPOST_MERGE_SMOKE_FAILEDr") r#rr8r:r9r>r<rr reason_mapr recommendedrs r$build_smoke_failed_packetr(s" H? }BOoJ L HK$&,,!++#//#//&55"\\(,,/99; H' .FF~~fo6 Z"&  r&TF)rCrrroutput_cap_bytesskip_stale_checkexpected_task_idc |xst}|jd} |xs t| |} t| | } | r t | |rdn t ||} | i|rt || | |Stdddddd } t| ||| tjdd d | i| }t|| tj| d dd|| | Sdj| }tjtj } || |}t'tjtj |z j)dz}t-|dd}t+t-|ddxsd|}t+t-|ddxsd|}|d k(r5t|dd ||d } t|| tj:| || | d| | St|d|||d| } t| ||| tj8| |d | i| }t|| tj8| || d|| | S#t"j$$r}t'tjtj |z j)dz}t+t-|ddxsd|}t+t-|ddxsd|}t|dd||d } t| ||| tj.| |d | i| }t|| tj.| || d|| | cYd}~Sd}~wt0$r}t'tjtj |z j)dz}t|dddt+t3||dt5|j6 } t| ||| tj8| |d | i| }t|| tj8| || d|| | cYd}~Sd}~wwxYw)utask spec 기준 main smoke 실행. Args: task_file: task md 절대경로 merge_commit: 자동 머지된 commit SHA dry_run: smoke_command가 None일 때만 의미 있음. None+dry_run=True → SKIPPED, None+dry_run=False → BLOCKED. smoke_command가 정의된 경우 dry_run과 무관하게 항상 실제 실행 (회장 §10 표 정합). runner: subprocess wrapper (test injection) pr_number: PR 번호 (없으면 0) timeout_sec: subprocess timeout (default 600). escalation evidence에 그대로 기록. output_cap_bytes: stdout/stderr head/tail cap (default 64KB) skip_stale_check: True면 main HEAD 비교 skip (test 격리용) expected_task_id: 외부에서 task_id를 직접 주입 (testing) Returns: PostMergeSmokeRun envelope. stale=True가 발견되면 PASS여도 allow_continuation=False로 강등된다 (자동 머지 큐 진행 차단). rp)encodingFN)r8r#rBrCrorz7smoke_command undefined; auto-merge requires definitionSMOKE_COMMAND_UNDEFINEDcommandpassedrrrrrrB) r#rr8r:r9r>r<rr r8r#r9r:r<r>r@rArBrC rirstderrr/zRUNNER_ERROR: rTEXIT_)r^ read_textrrrmr_build_skipped_runrrr+r0r6joinrrrrrZTimeoutExpiredr; total_secondsrrr/rr7typer1r-r,)rr8rCrrrrrrrr#r>rBsrpacketcmd_strstartedresultrr<rrrcs r$run_post_merge_smokerds&> &F##W#5IG/)Y"GG))W=M%m4&E+@v+VE %)  Q4  +y%B&&d7E*:#  !%w&&R$   hh}%Gll8<<(G.  {;^x||HLL1G;JJLtSTK r *B#GFHb$A$GRIYZK#GFHb$A$GRIYZK Qw DA# !%w##"#=#(yT    [rd| B '9!}%0@ F !7b} VW  ]  $ $ 8<< 5?NNPSWWX 'Xr(B(HbJZ[ 'Xr(B(HbJZ[ ER#$  +y%B&&m#We4D#  !%w&&R#=$     8<< 5?NNPSWWX ER)#c(4DE+DI,>,>+?@   +y%B##=#We4D#  !%w##"#=$    s26 HO+C K>8O> O CO OO)r>c |rdj|nd}t|dddd|sdnd}t||tj|d|dd|| S)NrroTrr.rr)rrr6r+r.)r8r#rBrCr>rrs r$rr sa*7chh}%BG B(5y4 B !7""]DW  r&ctjd}|jddd|jddd|j}|jd d d |jd d d |jdd d |jdtdd|jdtt |jdd d |j |S)Npost_merge_smoke_runner)progz --task-fileTutask md 절대 경로)requiredhelpz--merge-commitu자동 머지된 commit SHAz --dry-run store_trueuOsmoke_command 미정의 시 SKIPPED 처리 (정의된 경우는 항상 실행).)actionrz--applyuLsmoke_command 미정의 시 BLOCKED 처리 (정의된 경우 항상 실행).z --no-auditu'audit 로그 기록 skip (테스트용)z --pr-numberruPR 번호 (없으면 0))rdefaultrz --timeout)rrz--skip-stale-checkuorigin/main HEAD 비교 skip)argparseArgumentParser add_argumentadd_mutually_exclusive_groupr;DEFAULT_TIMEOUT_SEC parse_args)argvpmodes r$ _parse_argsr$s%>?ANN=46MNNNN#d9VNW ) ) +DL ^ , [NN< ;dNeNN=sAr=r<r;rzOptional[dict]rr;rQr)rr r8r7rCr?rzOptional[RunnerType]rr;rr;rr;rr?rr rQr6) r8r7r#r7rBr?rCr?r>r=rQr6rM)rr=rQzargparse.Namespace)rr=rQr;)GrS __future__rrrNloggingosrrrZsys dataclassesrrrrenumrpathlibr typingr r r environr"r7__file__resolveparentr\_HEREpathinsertutils.automation_contractsrrr getLoggerr1rrDEFAULT_OUTPUT_CAP_BYTESrvrwr rTr%r)r+r6r r^rhrmrcompileDOTALLrrrrrrrrrrrrexitr4r&r$r!sJ #   )'**  0#d8n6L6L6N6U6U6\6\2]^ _  X ''..u:SXXHHOOAs5z"   8 $ $7 (2<'1<'1<'1< .*( POWUZ 0,#t (*(* (*^c3h  ;?ObM 4 7O03RYY?RZZ :BLLI/ <BB&**5 55 5  5  5'55#555@#'*4"&*fff f ! f  ffff$ffV*.#&/3>B&.( * z CHHTVr&