3j+PUdZddlmZddlZddlZddlmZmZddlm Z ddl m Z m Z m Z mZmZmZdZded <d Zded <d Zded <dZded<dZded<dZded<dZded<dZded<dZded<dZded<dZded<dZded<ded Zded!<Gd"d#eZ Gd$d%e!Z" d1d&Z#eGd'd(Z$dd) d2d*Z%eGd+d,Z&d3d-Z'd4d.Z(d5d/Z)gd0Z*y)6uk anu_v3.coordinator_profile_binding — batch coordinator ← profile decision output 소비 seam. task-2553+39 TRACK B (회장 GO 병렬 4트랙 Track B, 9-R.1 우선). 목표 (회장 verbatim §1): batch coordinator 가 policy profile engine 의 decision output (gate / HOLD / allowed / forbidden / completion-packet / evidence schema)을 직접 소비하여 track 판단·통합에 활용한다. 9-R.1 (HIGH 해소, 본문 우선): "직접 소비" 의 결선 산물 = **이 신규 additive 모듈 자체가 coordinator-consumable binding seam(파일레벨 contract)**. +37 entrypoint· +29/+30 별도모듈 선례 동일 패턴 — 신규 binding 모듈이 곧 소비 연결점이며 frozen ``parallel_batch_coordinator.py`` / +29 registry / +30 generic coordinator 의 in-place 편집·import 결합 불요. "직접 소비" 달성 = binding 모듈 존재 + 파일레벨 contract + regression 으로 coordinator → engine output 소비 경로 입증. 기존 coordinator 가 이 binding 을 실 호출하는 in-place adoption 은 별도 운영단계. 설계 invariant (§3 / §5): - 신규 별도 모듈 (additive). engine·+29·+30·frozen coordinator 원본 무수정. **import 결합 0** — anu_v3 import 전무, 순수 stdlib only. - engine decision output 은 **파일레벨 contract** 로만 소비: ``anu_v3.policy_profile_engine.decision.v1`` JSON 형태(파일 or dict)를 read-only 입력으로 받는다 (engine 모듈 import·호출·mutation 0). - coordinator = 판단보조 소비만. closeout / merge **자동확정 0** — binding output 은 어떤 입력에서도 ``closeout_authority`` / ``merge_authority`` / ``auto_confirm`` 를 절대 True 로 내지 않는다 (hard-pinned False, fail-closed). - engine 부재 / schema mismatch → fail-closed 안전 (자동확정 0, coordinator 가 settle 못 하도록 HOLD/UNAVAILABLE 신호). - fallback safety path / callback mandatory rule / runtime checkpoint recovery layer 약화·격상·대체 0 (이 모듈은 그 경로를 만지지 않는다). - 모든 decision-logic 메서드 = derive / propose / read only. 파일 I/O 는 decision 경계 밖의 명시 hard-guarded helper 1개(`emit_binding`)에 한정. - NO-SCHEDULER: 스케줄러/외부 dispatch tooling 호출 0 (decision 경계 밖 I/O 는 hard-guarded helper 1개 한정, 그 외 부작용 전무). ) annotationsN) dataclassfield)Path)AnyDictFinalListMappingOptionalz"anu_v3.coordinator_profile_bindingz Final[str]BINDING_MODULEztask-2553+39.B.v1BINDING_VERSIONz%anu_v3.coordinator_profile_binding.v1BINDING_SCHEMAz(anu_v3.policy_profile_engine.decision.v1ACCEPTED_DECISION_SCHEMARESOLVED_DECISION_RESOLVEDHOLD_FOR_CHAIR_DECISION_HOLD CONSUME_OKENGINE_DECISION_HOLDCONSUME_HOLD_ENGINERUNTIME_HOLD_OBSERVEDCONSUME_HOLD_RUNTIMEDECISION_UNAVAILABLECONSUME_UNAVAILABLEz#task-2553.parallel-batch-state.json_FROZEN_DURABLE_V1z!.coordinator-profile-binding.json_DELIVERABLE_SUFFIXz"binding_schema": ""_DELIVERABLE_MARKERc$eZdZdZdfd ZxZS)CoordinatorProfileBindingErroruJbinding 소비 실패. ``self.code`` = 실패 사유 코드 (fail-closed).cLt|d|d|||_||_y)N[] )super__init__codemessage)selfr'r( __class__s 9/home/jay/workspace/anu_v3/coordinator_profile_binding.pyr&z'CoordinatorProfileBindingError.__init__Ks+ 1TF"WI./  )r'strr(r-returnNone)__name__ __module__ __qualname____doc__r& __classcell__)r*s@r+r!r!HsTr,r!ceZdZdZy)FrozenWriteRefuseduchair durable v1 / git-tracked / unrelated untracked 파일 write 거부. binding authority 는 별도 NEW untracked deliverable 이어야 한다 (§4/§5).N)r0r1r2r3r,r+r6r6QsZr,r6ct|tr t|}n4t|} |j d} tj|}t|ts"t d d t|j|jd }|tk7rt d d td|d|S#t $r}t dd|d||d}~wwxYw#tj$r}t dd|d||d}~wwxYw)u=C1 engine 의 decision output(``decision.v1``)을 read-only 소비. source = 파일 경로 또는 이미 로드된 dict (engine 모듈 import·호출 0 — 파일레벨 contract 만). schema marker mismatch / 파일 부재 / 파싱 실패 = fail-closed (CoordinatorProfileBindingError, code 보존). utf-8encodingdecision_source_unreadableu,engine decision output 부재/읽기 실패 z: Ndecision_source_unparsableu*engine decision output JSON 파싱 실패 decision_not_objectu)decision output 최상위 object 아님: schemadecision_schema_mismatchz*engine decision schema mismatch: expected z, got u@ (engine 부재/버전 mismatch — fail-closed, 자동확정 0)) isinstancer dictr read_textOSErrorr!jsonloadsJSONDecodeErrortyper0getr)sourceobjprawer?s r+load_profile_decisionrOYs6&'"< L ++w+/C  **S/C c4 , !7S 8J8J7K L  WWX F )), &8'*& ;N O  J3 0,>qcA3G  ## 0,B :  ( 8>B+ :+ + ^>B :  r,rQ)rc. t|}t|j|S#t$rd}tttt dddddddddt d|jd|jd ddddggdd d d d |jd cYd}~Sd}~wwxYw)ubatch coordinator → profile decision output 소비의 단일 callable entrypoint. engine decision output(파일레벨 contract)을 read-only 로 소비해 coordinator-consumable binding contract 를 반환한다. engine 부재/mismatch 는 fail-closed safe binding 으로 변환(예외를 coordinator 가 settle 신호로 오인하지 않도록 DECISION_UNAVAILABLE). u/read-only fail-closed (engine 부재/mismatch).NrF UNAVAILABLE)rrrrr_r#r$r)rrrrrugcoordinator=판단보조 소비만; closeout/merge 자동확정 0 (fail-closed 경로에서도 불변).T) rrrrrrrrrr fail_closed error_code) rOr!rr rrrr'r(rQr)rJrrSrNs r+consume_for_coordinatorr9s" (0D %X . < <_ MMC *  ,,.(@O!%)$<&+#( %!. '.affXR {33 %&+#(!&35UT %8 &&=    s ' BAB BBc4eZdZUded<eeZded<y)BindingFixturerRrS)default_factoryrN)r0r1r2rrrBrr7r,r+rrns&+D&AO^Ar,rc tjt|jd}t t |dt |j diS)Nr9r:rSr)rSr)rErFrrCrrBrI) fixture_pathdatas r+load_binding_fixturertsQ ::d<(22G2D ED d:&'TXX&7<= r,c ^ tjddt|jddgdd}|jdk7ry|j j }tjdd|d d t|jgdd}|jdk(S#t$rYywxYw) Ngitz-Cz rev-parsez--show-toplevelT)capture_outputtextrFzls-filesz--error-unmatch) subprocessrunr-parent returncodestdoutstripresolve Exception)rLtopreporcs r+_is_git_trackedrsnn D#ahh-6G Hd  >>Q zz! ^^ D$ ,=s199;?O Pd }}!! s?B AB B,+B,ct|}|jtk(r tdt |rtd|d|j rK|jj t}|s t|jdv}|std|d|jjd d |jtj |dd d zd|S#ttf$rd}YowxYw)uYNEW untracked binding authority 파일 write. decision component 아님 — runner/ANU 가 수행하는 명시 I/O (9-R.1 경계 밖). Hard write-guard (§4/§5 — +30 가드 미러, 무관 파일 절대 clobber 0): * chair durable v1 name -> REFUSE (byte-0 immutable) * git-tracked path -> REFUSE (tracked HEAD invariant) * untracked & non-existent -> ALLOW (NEW deliverable) * untracked & existing sanctioned -> ALLOW (idempotent re-emit) * untracked & existing non-deliver. -> REFUSE (무관 파일 보호) uorefusing to write chair durable v1 (§5 byte-0); binding authority MUST be a separate NEW untracked deliverablez#refusing to write git-tracked path uA (§5 tracked HEAD invariant — only NEW untracked deliverables)r9r:Fz9refusing to overwrite existing untracked non-deliverable zR (only a NEW untracked path or this seam's own binding deliverable may be written)T)parentsexist_ok) ensure_asciiindent )rrbrr6rexistsendswithrrrCrDUnicodeDecodeErrorrmkdir write_textrEdumps)bindingout_pathre sanctioneds r+ emit_bindingrs$ x.C xx%%  E  s 1#7= =   zz|XX&&':;  #0CMM$5B5 $K%67  JJTD1NN 7q9D@ J/0 #"  #s6C**C>=C>)r rrrrrrrr!r6rQrrOrrr)rJ 'str | Path | Mapping[str, Any]'r.rR)rJrrrr.rR)r 'str | Path'r.r)rLrr.r)rzMapping[str, Any]rrr.r)+r3 __future__rrEr dataclassesrrpathlibrtypingrrr r r r r rrrrrrrrrrrrr ValueErrorr! RuntimeErrorr6rOrQrrrrr__all__r7r,r+rsk%L# (<<A A11D D(R*Q",J+- -& J%"8Z8#:j:"8Z8"GJF"EZE$77Gq"IZIZZZ( ,((\ k k  k h48/N ,/N1/N /Nj BB B $*Z r,