jKdZddlmZddlZddlZddlZddlmZmZddl m Z m Z m Z ddl mZddlmZdZd Zd Zd ZeeehZd Zd+d ZedGddZd,dZd-dZdZeGddZd.dZd/dZ d0dZ d1dZ!d1dZ"dZ#dZ$dZ%dZ&d Z'ed! d2d"Z(d3d#Z)ed! d4d$Z*ed! d5d%Z+d6d&Z,d7d'Z-d8d9d(Z.ded) d:d*Z/y);u0 dispatch.executor_completion_contract — executor completion callback contract. task-2553+32 — EXECUTOR COMPLETION CALLBACK MANDATORY RULE 복원 (코드/파일 자동화). 회장 정정 (memory/events/task-2553.normal-callback-mandatory-doctrine-correction _260518.json): executor completion callback = MANDATORY lifecycle signal. NO-CRON ≠ executor completion callback 금지. This standalone module encodes that rule as executable code so that ANY future executor task cannot omit its normal completion callback (§1/§4). Standalone, zero-mutation: imports/edits ZERO tracked module. The huge dispatch/__init__.py body is NOT touched (§8 기존 산출물 수정 0). File-level contract only — the same pattern as anu_v3.callback_4tuple_index / anu_v3.result_ready_recovery (+29). NO-CRON note (9-R.1): this module performs ZERO cron register/remove. It only *declares and validates* the contract. The executor's normal completion callback is a designed lifecycle signal — NOT an ad-hoc cron-add by the registry/checkpoint, and NOT a cron-remove by +32 (회장 금지 준수). Closeout note (9-R.2): requiring an executor's own normal-completion callback / result.json / report / .done is a *lifecycle signal*, NOT an escalation of repository/task-state finalization authority. The latter (closeout 확정 권한) remains forbidden; the former is REQUIRED. ────────────────────────────────────────────────────────────────────────────── L4 wiring (task-2630 — CALLBACK_RUNTIME_ENFORCEMENT L4): callback lifecycle classifier 실결선. 이 모듈에 result.json fields 10~14(축A/B/C lifecycle 분류)를 **append-only** 로 확장하고, `memory/events/.callback_lifecycle.json` artifact writer 를 추가한다 (스펙 memory/specs/system_callback_lifecycle_state_schema_260522.md §8/§9). zero-mutation 원칙 유지: 기존 9-field per-callback contract (dispatch.normal_fallback_callback_helper._contract_fields, 회장 §10) 는 그대로 보존하고 위 5개 lifecycle field 만 덧붙인다(ANCHOR-2). 신규 의존은 `utils.callback_lifecycle_classifier` (순수 함수 · 파일/네트워크/subprocess I/O 0 · anu_v3 런타임 import 0) 하나뿐 — 기존 tracked module **본문**은 수정하지 않는다. artifact writer 외 어떤 cron register/remove · callback 재발사 · subprocess 도 수행하지 않는다(§11 / ANCHOR-4: production enforcement 완료 판정은 L4 merge 후 별도). ) annotationsN) dataclassfield)DictListOptionalclassify_callback_lifecycle)DEFAULT_ANU_KEYSz(dispatch.executor_completion_contract.v1NORMAL_COLLECTOR_COMPLETEDRESULT_READY_NO_NORMAL_CALLBACKDISPATCH_FAILEDaRNO-CRON == registry/checkpoint(+29/+30/+31) MUST NOT arbitrarily add/remove cron. It does NOT mean the executor is forbidden from sending its normal completion callback. The executor normal completion callback is a MANDATORY lifecycle signal, not a registry-initiated ad-hoc cron, and is therefore explicitly exempt from the cron-add ban.cy)u§6.5 — executor completion callback is NOT a 'cron 신규 등록 금지' breach. Always False: the normal completion callback is a designed lifecycle signal, distinct from a registry/checkpoint ad-hoc cron add. FrV/home/jay/workspace/.worktrees/task-2644-dev1/dispatch/executor_completion_contract.py0is_executor_completion_callback_a_cron_violationrPs rT)frozenc:eZdZUdZded<ded<ded<ded<y) Callback4Tupleu{task_id, dispatch_cron_id, normal_collector_cron_id*, fallback_cron_id}. normal_collector_cron_id is MANDATORY (§4.5). A None/empty value makes the contract invalid (§6.12) — it is NOT a valid NO-CRON degradation. strtask_iddispatch_cron_id Optional[str]normal_collector_cron_idfallback_callback_cron_idN)__name__ __module__ __qualname____doc____annotations__rrrrrZs  L++""rrcg}|js|jd|js|jd|js|jd|js|jd|S)u3Return invalidity reasons (empty == valid). §6.12.z task_id emptyzdispatch_cron_id emptyu{normal_collector_cron_id missing — MANDATORY lifecycle signal (§4.5/§6.12). NO-CRON does NOT exempt this (§6.3/§6.5).u4fallback_callback_cron_id empty (safety path, §6.6))rappendrrr)treasonss rvalidate_4tupler&hshG 99'  /0 % % J  & &MN Nrct| SN)r&)r$s rtuple_is_validr)ysq! !!r)result_json_presentdone_marker_presentreport_present%normal_callback_registration_evidencec~eZdZUdZded<dZded<dZded<dZded<dZded <dZ ded <e e Z d ed <y)ExecutorCloseoutEvidenceFboolr*r+r,r-Nrrclaims_finalization_authority)default_factory List[str]notes) rrrr*r!r+r,r-rr1rlistr4rrrr/r/sV %% %% ND 38)47.2m2+0!4/T2E92rr/cfg}|js|jd|js|jd|js|jd|js|jd|j s|jd|j r|jd|S)uFAIL reasons for an executor closeout (§4.4 / §4.6 / 9-R.2). Missing normal callback registration evidence == FAIL (not a valid closeout) even when result.json/.done/report all exist. zresult.json missingz.done marker missingzreport missingunormal callback registration evidence missing — executor normal completion callback is MANDATORY (§4.4/§4.6). Not a valid normal lifecycle completion.u<normal_collector_cron_id absent in closeout evidence (§4.5)uzcloseout evidence claims repository/task-state finalization authority — forbidden (9-R.2/§6.15). Lifecycle signal only.)r*r#r+r,r-rr1)evr%s rvalidate_closeout_evidencer8s G ! !,- ! !-.  '( 3 3 1  & & J  '' M  Nrct| Sr()r8)r7s rcloseout_is_validr:s)"- --rcJ|stS|xs|}|rtS|rtStS)u§4.6 / §6.8 / §6.9 completion classifier. result.json + .done exist but normal callback never registered -> RESULT_READY_NO_NORMAL_CALLBACK (a recovery state, NOT a normal lifecycle complete). )rr r ) dispatch_okresult_present done_presentnormal_callback_registered has_results rclassify_completionrAs/ /.callback_lifecycle.json` artifact 내용(dict) 구성 — 순수·결정적. 동일 입력 → 동일 출력 (I/O 0). fallback collector artifact 와 구분되도록 artifact_kind 를 명시한다(필수구현 6). rYrLrIrJrKevidence_completenessmissing_evidence_sourcesrDrMrNr) schema artifact_kindrrIrJrKrwrxrDrLrirMrN)r]"CALLBACK_LIFECYCLE_ARTIFACT_SCHEMA CALLBACK_LIFECYCLE_ARTIFACT_KINDrirf)rr\rZrrrgs r!build_callback_lifecycle_artifactr}Js+8h GF + ,C49"#56&,-I&J!"34!'(?!@$*+E$F !12$'%>s%C0)!< rc:tj|ddddzS)u결정적 직렬화 — sort_keys + 고정 indent + trailing newline. 동일 dict → byte-identical 문자열 (idempotent artifact 보증). FT) ensure_ascii sort_keysindent )jsondumps)artifacts r_serialize_lifecycle_artifactrfs ::hUd1 MPT TTrctjjd}|r!tjj |ddStjj tjj t}tjj tjj |ddS)uartifact 기본 디렉터리 = /memory/events. WORKSPACE_ROOT env override 우선(테스트 live-workspace 의존 0 보장), 없으면 이 파일(dispatch/) 기준 repo 상대 경로로 해석. WORKSPACE_ROOTmemoryevents)osenvironrfpathjoindirnameabspath__file__)rootheres rdefault_events_dirrnst ::>>* +D ww||D(H55 77??277??84 5D 77<<-x BBrcn||n t}tjj||tS)uFartifact 파일 경로. events_dir 미지정 시 default_events_dir().)rrrr"CALLBACK_LIFECYCLE_ARTIFACT_SUFFIX)r events_dirrqs r callback_lifecycle_artifact_pathr{s2#/:5G5ID 77<< *L)MN OOr)rrZct|||}t|}t||}d} t|dd5}|j }ddd||k7rtjj|xsd} tj| dtj| d d \} } tj| d d5}|j|dddtj | ||S|S#1swYxYw#t t tf$rYwxYw#1swYIxYw#t"$r' tj$| #t&$rYwxYwwxYw) u`memory/events/.callback_lifecycle.json` 기록 (idempotent · 필수구현 3). - 동일 입력 2회 실행 → byte-identical (결정적 직렬화). - 기존 파일 내용이 이미 동일하면 재기록하지 않는다(중복 write 0 · mtime 보존). - cron 0 · callback 재발사 0 · subprocess 0 — 오직 lifecycle artifact 파일 1개만 생성/갱신한다(필수구현 6: fallback collector artifact 미접촉). 반환: artifact 파일 절대/상대 경로. rYNrzutf-8)encoding.T)exist_okz.callback_lifecycle.z.tmp)dirprefixsuffixw)r}rropenreadFileNotFoundErrorIsADirectoryErrorPermissionErrorrrrmakedirstempfilemkstempfdopenwritereplace BaseExceptionunlinkOSError) rr\rrZrpayloadrexistingfhdirpathfdtmps r!write_callback_lifecycle_artifactrsQ1(XVH+H5G +GZ @D"H $g . !"wwyH !7''//$'.3 Gd+""w7MV\]C 2sW5 "! " JJsD ! K4K) ! ! 0/ B    " "   #     spDC7D+D)DD)7D<DDDD&"D)) E3E E EEEE)returnr0)r$rrr3)r$rrr0)r7r/rr3)r7r/rr0) r<r0r=r0r>r0r?r0rr)rDrrr0)r\rrr)rLrrr)rprr\rrr)rrr\rrr)rrrr)rrr()rrrrrr)rrr\rrrrr)0r __future__rrrr dataclassesrrtypingrrr#utils.callback_lifecycle_classifierr utils.callback_lifecycle_statesr CONTRACT_SCHEMAr r r frozensetNON_NORMAL_LIFECYCLENO_CRON_CORRECTED_DEFINITIONrrr&r)EXECUTOR_CLOSEOUT_CHECKLISTr/r8r:rArErGLIFECYCLE_RESULT_FIELDSCALLBACK_CONTRACT_9_FIELDSr{r|rr]rirur}rrrrrrrrs*V# (''K<<:#D#!$o6 M $ # # #""  3 3  3>.  !%   .8 =" &O" $C %?"!1 D D  D*:J'+ B/?   8U CP!%  * ** *  *r