Ë
    PJjO  ã                  óˆ   — d Z ddlmZ ddlmZ ddlmZmZmZm	Z	 ddl
mZmZmZmZ ddlmZmZmZ dZdZd	Zdd
„Zdd„Zg d¢Zy)ur  anu_v3.operational_collector_wiring â€” operational collector wiring ë³´ê°•.

task-2553+45 (íšŒìž¥ Â§5 â€” ``anu_v3/operational_collector_wiring.py`` ë³´ê°•).

íšŒìž¥ Â§3 verbatim: "ì‹¤ì œ normal collector ê²½ë¡œê°€
``operational_collector_wiring::run_operational_completion_callback_collector``
ë¥¼ ê²½ìœ í•˜ê²Œ í•œë‹¤." ê¸°ì¡´ +25 ì‚°ì¶œ(``utils/operational_collector_wiring.py``)Â·
+37 ì‚°ì¶œ(``utils/normal_completion_callback_collector_entrypoint.py``)ì€ Â§8/
Â§5 ì— ì˜í•´ **ë¬´ìˆ˜ì •**ì´ë‹¤. ë³¸ ëª¨ë“ˆì€ anu_v3 namespace ì˜ **strict-additive
read-only ë³´ê°• ë ˆì´ì–´**ë¡œì„œ:

  1. +25 ``run_operational_completion_callback_collector`` ì™€ +37
     ``run_wired_normal_completion_callback_collector`` ê³µê°œ ì‹¬ë³¼ì„
     read-only re-export í•œë‹¤ (ê¸°ì¡´ í˜¸ì¶œì§€ì  ë¬´ë³€, ì‹ ê·œ import ê²½ë¡œ ì œê³µ).
  2. live normal collector cron prompt ê°€ ê²°ì„ í•´ì•¼ í•  ë‹¨ì¼ live
     entrypoint(``anu_v3.cancel_on_success_live_wiring.
     run_cancel_on_success_live_wiring``)ë¥¼ ``resolve_live_collector_
     entrypoint()`` ë¡œ ë…¸ì¶œí•œë‹¤ â€” durable 4-tuple registry(+44) lookup +
     canonical-first root(+46) + +37â†’+25â†’+23 seam ê²½ìœ ê°€ ë³´ìž¥ë˜ëŠ” ê²½ë¡œ.

Layer A / NO-CRON (9-R.1): re-exportÂ·resolver ë§Œ. ZERO cron register/
remove, ZERO dispatch, ZERO merge, ZERO ``cokacdir``/``subprocess`` exec.
ì›ë³¸ +25/+37 ëª¨ë“ˆ byte-0 (import ë§Œ, 1 byte ìˆ˜ì • 0).
é    )Úannotations)ÚCallable)ÚCancelOnSuccessLiveResultÚDurableFallbackLookupÚ%lookup_fallback_from_durable_registryÚ!run_cancel_on_success_live_wiring)ÚOperationalSeamParamsÚOperationalWiringResultÚcompute_event_idÚ-run_operational_completion_callback_collector)ÚNormalCallbackBindingÚWiredCollectorResultÚ.run_wired_normal_completion_callback_collectorz&anu_v3.operational_collector_wiring.v1zFanu_v3.cancel_on_success_live_wiring.run_cancel_on_success_live_wiringu.  run_cancel_on_success_live_wiring â†’ durable 4-tuple registry lookup (anu_v3.callback_4tuple_registry, +44) + canonical-first root (anu_v3.artifact_root_resolver, +46) â†’ utils.normal_completion_callback_collector_entrypoint.run_wired_normal_completion_callback_collector (+37, PRIMARY) â†’ utils.operational_collector_wiring.run_operational_completion_callback_collector (+25) â†’ utils.completion_callback_operational_cancel_seam.run_operational_cancel_seam(operational=True) (+23) â†’ utils.live_cron_state_verifier 5ì¡°ê±´ AND â†’ +9a bound cron-removec                 ó   — t         S )uõ   live normal collector cron ì´ ê²°ì„ í•´ì•¼ í•˜ëŠ” ë‹¨ì¼ callable ì„ ë°˜í™˜.

    íšŒìž¥ Â§3 ê²°ì„  â€” ì´ callable ì„ ê²½ìœ í•˜ë©´ durable-success í›„
    operational cancel seam ì´ durable-boundÂ·verified 1ê±´ì— í•œí•´ ìž‘ë™í•œë‹¤.
    )r   © ó    ú:/home/jay/workspace/anu_v3/operational_collector_wiring.pyÚ!resolve_live_collector_entrypointr   M   s
   € ô -Ð,r   c            	     ó0   — t         t        t        ddddddœS )uJ   ê²°ì„  ê³„ì•½ (collector cron prompt ê°€ ë°•ì•„ì•¼ í•˜ëŠ” routing ê³„ì•½).zdurable_4tuple_registry (+44)zcanonical-first (+46)zbrun_cancel_on_success_live_wiring (registry/checkpoint = recovery layer only, never replaces this)un   deliverable ëª¨ë“ˆ ìž„ì˜ cron ì¡°ìž‘ 0 â€” re-export/resolve/lookup + +37 ê²½ìœ ë§Œ, ZERO cokacdir/subprocessuh   durable lookup + live verifier 5ì¡°ê±´ AND PASS = single boundÂ·verified cancel 1ê±´ (íšŒìž¥ Â§1 ëª©í‘œ))ÚschemaÚlive_collector_entrypointÚwiring_chainÚfallback_cron_id_lookup_sourceÚartifact_root_resolutionÚprimary_pathÚlayer_a_no_cronÚlayer_b_single_bound_cancel)ÚWIRING_SCHEMAÚLIVE_COLLECTOR_ENTRYPOINTÚLIVE_WIRING_CHAINr   r   r   Úlive_wiring_contractr!   V   s,   € ô  Ü%>Ü)Ø*IØ$;ð8ð8ð>ñð r   )r   r   r    r   r!   r   r   r   r   r	   r
   r   r   r   r   r   N)Úreturnr   )r"   Údict)Ú__doc__Ú
__future__r   Útypingr   Ú$anu_v3.cancel_on_success_live_wiringr   r   r   r   Ú"utils.operational_collector_wiringr	   r
   r   r   Ú5utils.normal_completion_callback_collector_entrypointr   r   r   r   r   r    r   r!   Ú__all__r   r   r   ú<module>r+      s]   ðñõ0 #å ÷ó ÷ó ÷ñ ð 9€ð
(ð ð	Kð ó-óò.r   