3j9UdZddlmZddlmZmZddlmZddlm Z m Z m Z m Z ddl mZmZmZmZmZmZmZdZded <d Zded <d Zded <dZded<dZded<dZded<dZded<dZded<dZded<GddeZ eGddZ!d*dZ"eGdd Z#ed! d+d"Z$d,d#Z%eeed$ d-d%Z&eeed$ d.d&Z'd/d'Z(gd(Z)y))0u anu_v3.dispatch_profile_selection — TRACK A: profile engine → dispatch selection 연결 seam (task-2553+38). 회장 GO 병렬 4트랙 Track A. +33 C1 engine(`anu_v3.policy_profile_engine`, 정본 API parse_goal_request→resolve_policy, byte-0)을 **실 운영 dispatch selection 경로에 연결**하는 신규 additive 결선 모듈. 9-R.1 (본문 우선): 본 모듈 **자체가 운영 dispatch selection 연결 seam** 이다 — callable entrypoint(`select_profile_for_dispatch` / `run_dispatch_profile_selection`) + 파일레벨 contract. +37 `normal_completion_callback_collector_entrypoint` 선례와 동일 패턴: 신규 seam 모듈이 곧 연결점이며, 기존 frozen/tracked dispatch 코드 in-place 편집은 불요하다. "연결" 달성 = seam 모듈 존재 + 입출력 contract + regression 으로 dispatch→engine 경로 입증. 기존 dispatch 경로가 이 seam 을 호출하도록 하는 실 채택(in-place adoption)은 별도 운영단계 (본 task 는 seam+contract+regression 으로 결선 완성). 본 모듈 한정 책임 (순수, 부작용 0 — 파일 쓰기 0, network 0, git 0, GitHub API 0, 실 dispatch 실행 0): - dispatch selection 요청(goal_type + policy_profile + boundary) 정규화 - C1 engine **read-only 소비**: parse_goal_request → resolve_policy (정본 API. engine import 만, engine 객체 mutation 0, engine byte-0) - PolicyResolution → dispatch 가 그대로 소비할 selection binding 산출 - profile 부재 / mismatch / engine HOLD → **안전 거부(자동 적용 0)**: 예외를 dispatch lifecycle 로 전파하지 않고 SELECTION_REFUSED / HOLD_FOR_CHAIR 결정 dict 로 fail-closed 변환 (dispatch 무파괴) - decision/result JSON 산출 (DispatchProfileSelection.to_decision_dict) 설계 invariant: - 신규 별도 모듈 (strict-additive). 기존 anu_v3 tracked 파일·engine· frozen anchor·+22~+37 원본 import-only / mutation 0. - engine 은 `anu_v3.policy_profile_engine` 정본 API 만 호출 (parse_goal_ request, resolve_policy, PolicyEngineError). engine 내부 재구현 0. - seam 은 dispatch 를 **선택만** 하고 **실행하지 않는다** — `DISPATCH_LIFECYCLE_EFFECT = "none"`. 실 운영 적용은 결선 후 별도. - 외부 의존성 0 (engine 과 동일 — offline 100%). ) annotations) dataclassfield)Path)AnyFinalMappingSequence)PROFILE_JSON_DIR_DEFAULTPROFILE_SCHEMA_DIR_DEFAULTSCHEMA_DIR_DEFAULTPolicyEngineErrorPolicyResolutionparse_goal_requestresolve_policyz!anu_v3.dispatch_profile_selectionz Final[str] SEAM_MODULEztask-2553+38.A.v1 SEAM_VERSIONz$anu_v3.dispatch_profile_selection.v1SELECTION_SCHEMA_IDnoneDISPATCH_LIFECYCLE_EFFECTSELECTEDSTATUS_SELECTEDSELECTION_REFUSEDSTATUS_REFUSEDHOLD_FOR_CHAIR STATUS_HOLDselection_request_not_mappingREFUSAL_REQUEST_NOT_MAPPING%selection_policy_profile_name_missingREFUSAL_PROFILE_NAME_MISSINGc$eZdZdZdfd ZxZS)DispatchProfileSelectionErroruseam 요청 정규화 실패. dispatch lifecycle 로 전파하지 않고 내부에서 SELECTION_REFUSED 로 변환된다 (안전 거부 — 자동 적용 0).cLt|d|d|||_||_y)N[z] )super__init__codemessage)selfr'r( __class__s 8/home/jay/workspace/anu_v3/dispatch_profile_selection.pyr&z&DispatchProfileSelectionError.__init__Ms+ 1TF"WI./  )r'strr(r-returnNone)__name__ __module__ __qualname____doc__r& __classcell__)r*s@r+r"r"IsOr,r"cbeZdZUdZded<ded<ded<dZded<ee Zd ed <d d Z y)DispatchSelectionRequestuOdispatch 가 seam 에 넘기는 입력 (goal_type + policy_profile + boundary).r-goal_idgoal_statementpolicy_profile_nameN str | None goal_type)default_factory list[str]boundaryc|j|jt|jd|jid}|j r|j |d<|S)uDC1 engine 정본 입력(goal_request_2553plus33.schema.json) 형태.name)r7r8r>policy_profiler;)r7r8listr>r9r;)r)grs r+to_goal_requestz(DispatchSelectionRequest.to_goal_request]sP||"11T]]+%t'?'?@   >>"nnB{O r,r.dict[str, Any]) r0r1r2r3__annotations__r;rrBr>rDr,r+r6r6Ss4Y L Iz 5Hi5 r,r6c t|ts&ttdt |j |j dxsi}t|tr|j dnd}|rt|tsttd|j d}tt|j ddt|j d d|t|tr |jr|jnd|j d xsgDcgc] }t|c} Scc}w) u"dispatch 가 넘긴 raw dict → DispatchSelectionRequest (fail-closed). engine 진입 *이전* 의 정규화. 형태 불량은 DispatchProfileSelectionError 로 raise 하되, seam entrypoint 가 이를 SELECTION_REFUSED 안전 거부로 흡수한다 (dispatch 무파괴). uselection request dict 아님: rAr@Nu!policy_profile.name 누락/무효r;r7r8r>)r7r8r9r;r>) isinstancer r"rtyper0getr-r r6strip)rawppr@gtbs r+build_selection_requestrSjs c7 #+ '-d3i.@.@-A B   ! " (bB'G4266&>$D z$,+ (*M    B #CGGIr*+377#3R89 *2s 3 "((*#&77:#6#<">Q#a&>   ?s$D>ceZdZUdZded<ded<ded<ded<ded<ded <ded <d ed <d ed<d ed<d ed<d ed<ded<ded<dZded<dZded<eZded<e Z ded<e Z ded<dZ ded<ddZddZy) DispatchProfileSelectionuKseam 산출 — dispatch 가 그대로 소비할 profile selection binding.r-statusbool profile_bound auto_applyr7r; profile_idprofile_versionrFr>r=gate_condition_nameshold_trigger_conditionsallowed_actionsforbidden_actionsr:completion_packet_meta_refevidence_meta_refN refusal_coderefusal_reasondispatch_lifecycle_effectseam seam_versionzdict[str, Any] | Noneengine_decisioncZidtd|jd|jd|jd|jd|j d|j d|jd |jd |jd |jd |jd t|jdt|jdt|jdt|j d|j"|j$|j&|j(|j*dS)NschemarerfrVrXrYrdr7r;rZr[r>r\r]r^r_r`)rarbrcrg)rrerfrVrXrYrdr7r;rZr[r>rBr\r]r^r_r`rarbrcrgr)s r+to_decision_dictz)DispatchProfileSelection.to_decision_dictsf ) DII  D--  dkk  T//  $//   ()G)G  t||    $//  t33     #D)B)B$C  &tD,H,H'I  tD$8$89 d&<&s>D#$L#$-1O*1 2 r,rU)rVcttdid|ddddddddddd dd id gd gd gdgddddd|d|S)uS안전 거부 결정 — profile 미바인딩·자동 적용 0, dispatch 무파괴.rVrXFrYr7rJr;rZr[r>r\r]r^r_r`NrarbrcrH)rU)r'reasonrVs r+_refusedrps $                !#   $(    ! r,c|j}|j}|jdk(rtdidtddddd|j d|j d|jd |jd |jd t|d d t|d d t|d dt|dd|dd|dddd|jd|Sttdd|j |j |j|j|jt|d t|d t|d t|d|d|d|S)u)PolicyResolution → dispatch selection. engine status RESOLVED → SELECTED(자동 적용 허용). HOLD_FOR_CHAIR → HOLD(자동 적용 0, profile 미바인딩 — fail-closed). engine read-only: res 는 resolve_policy 가 반환한 객체이며 본 함수는 읽기만 한다. rrVrXFrYr7r;rZr[r>r\r]r^r_r`rarbengine_hold_for_chairrcrgT)rVrXrYr7r;rZr[r>r\r]r^r_r`rargrH) to_coordinator_bindingrkrVrUrr7r;rZr[r>rB hold_reasonr)resbindingdecisions r+_from_resolutionrxs((*G##%H zz%%'    KK  mm  ~~   // \\ "&g.D&E!F %)1J)K$L !):!;< #7+>#?@ (//K'L &&9: 1 ??! "%#  & $ -->>++!'*@"AB $W-F%G HW%678w':;<#*+G#H!"56  r,profile_json_dirprofile_schema_dir schema_dirc|j} t||t||||}t|S#t$r*}t |j |j cYd}~Sd}~wwxYw)u]**연결 seam entrypoint** — dispatch 시 goal_type+policy_profile+ boundary 로 profile 을 자동 선택·로딩한다. C1 engine 정본 API 를 read-only 로 소비: parse_goal_request 로 요청을 검증한 뒤 resolve_policy 로 gate/HOLD/allowed/forbidden/evidence/ completion-packet 을 산출한다. engine mutation 0. profile 부재 / schema mismatch / engine HOLD 는 예외를 dispatch 로 전파하지 않고 **안전 거부(자동 적용 0)** 결정으로 fail-closed 변환한다 — dispatch lifecycle 무파괴 (`DISPATCH_LIFECYCLE_EFFECT == "none"`). )r|ryN)rDrrrrpr'r(rx)requestrzr{r| goal_requestrues r+select_profile_for_dispatchrsk$**,L +%k2 & )-  C    !! )> *;;==>s , A--A("A-(A-cD|Dcgc]}t|dc}Scc}w)uAfixture case[].request 목록 추출 (regression/dry-run 공용).r~)dict)casescs r+selection_requests_from_fixturerNs(- .1D9  .. .s)rrrrrrrrr r"r6rUrSrrrN)rOrr.r6)r'r-ror-rVr-r.rU)rurr.rU) r~r6rz str | Pathr{rr|rr.rU) rrrzrr{rr|rr.rF)rzSequence[Mapping[str, Any]]r.z list[Any])*r3 __future__r dataclassesrrpathlibrtypingrrr r anu_v3.policy_profile_enginer r r rrrrrrGrrrrrrrr ValueErrorr"r6rSrUrprxrrr__all__rHr,r+rs$L#(00> Z=. j."HZH)/:.)(0 0* Z*+JZI+RjRJ  ,8 @ @  @ H.< '*0-f$<%?/ ! % !! !# !  !  !L$<%?/ ""!"# "  "  "2/  r,