jddZddlmZddlmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZddlmZmZmZmZmZddlmZmZmZeddd  d d Zgd Zy) udispatch.core — dispatch + cancel + main + composite + PRD facade (task-2388 Phase ε). dispatch 패키지의 본체는 `dispatch/__init__.py`에 있다. 이 facade는 메인 dispatch 흐름 영역의 함수만 노출한다. 영역: - chain / cleanup - composite dispatch - PRD parsing - 메인 dispatch + retry - cancel / main entry point 본체 코드 무변경. ★ task-2640 (회장 verbatim unfork #2) — 봇 spawn 직전 callback contract validator 결선 추가. 새 함수 ``dispatch_to_bot_with_contract`` 가 spawn 진입점이며, ``validate_spawn_callback_contract`` 를 호출해 ANU-owned callback contract 정합성을 fail-closed 검증한다. 실패 시 cokacdir --cron 발사 0 + 분류 반환. ) annotations)OptionalSequence) _cleanup_task_dispatch_composite_parse_prd_claude_parse_prd_regex_retry_with_fallback_key_update_chain_task cancel_taskdispatch handle_prdmain) ANU_KEY_2553DEFAULT_ANU_KEYSFAILHOLDPASS)NO_OP_SPAWN_CONTRACT_FAILEDContractValidationResult validate_spawn_callback_contractNT)anu_keyanu_keysanu_keys_resolvablec| t|ntt}t||||||}|j}|jt k(rddi|Sdt d|S)u봇 spawn 직전 callback contract validator gate (회장 verbatim unfork #2). ANU-owned callback contract 부재 시 fail-closed (NO_OP_SPAWN_CONTRACT_FAILED). 실제 ``subprocess.run("cokacdir", "--cron", ...)`` 호출은 본 함수가 PASS 를 반환한 후에만 호출자(dispatch.dispatch / 외부 entrypoint)가 수행한다. Layer A / NO-CRON: 본 함수는 subprocess / cokacdir / merge / cron 0 호출. Args: task_id: spawn 대상 task id executor_key: spawn 대상 봇의 self key prompt: build_prompt 산출 본문 (텍스트 + 코드 contract 정합 검증) anu_key: independent ANU collector key (기본값 ``ANU_KEY_2553``) anu_keys: override 허용 ANU key 집합 anu_keys_resolvable: ANU key 집합 resolution 가능 여부 Returns: dict — { "status": "ok" | "blocked", "verdict": PASS|FAIL|HOLD_FOR_CHAIR, "classification": str | None, "classifications": [..], "reasons": [..], "schema": str, "task_id": str, "executor_key": str, "anu_key": str, "no_op_reason": NO_OP_SPAWN_CONTRACT_FAILED (FAIL only), } )task_id executor_keyr prompt_textrrstatusokblocked)r no_op_reason)tuplerrto_jsonverdictrr) rrpromptrrrkeysresultpayloads >/home/jay/workspace/.worktrees/task-2644-dev1/dispatch/core.pydispatch_to_bot_with_contractr+3sN'25?>N8OD'G!/ (FnnG ~~ d   3   )rrrr r r r r rrr+rrrrrr)rstrrr-r&r-rr-rzOptional[Sequence[str]]rboolreturndict)__doc__ __future__rtypingrrr rrrr r r r rr dispatch.callback_owner_enforcerrrrrr*dispatch.spawn_callback_contract_validatorrrrr+__all__r,r*r8s(#%    (, $; ;;  ;  ; & ;; ;| r,