j>dZddlmZddlZddlZddlZddlZddlZddlm Z dZ dZ dZ dZ d Zd Zd Zd Zd ZdZe e e eeeeegZeeDcic]\}}|| c}}ZdZej0j3edZej0j3edZdZ d ddZd dZ d!dZd"dZ d#dZ!d$dZ"d%dZ#d&dZ$d'dZ%d(dZ&d)dZ'ycc}}w)*uv3.6 Runtime Harness — Layer 2: Spawn Detector. chair_authorization_id=CHAIR-AUTH-TASK-2704-V36-CONTROL-PLANE-P0-MVP-260528 Contract: - detect_spawn_state(task_id, schedule_id) -> dict Returns {"state": <9-state enum>, "signals": {...}, "reason": str} - 9 states: NOT_REGISTERED, REGISTERED, FIRED, SESSION_SEEN, WORK_STARTED, ARTIFACT_SEEN, CALLBACK_REGISTERED, DONE, UNKNOWN - Cross-validation across ≥2 signals required for most states. - CRITICAL: When signals insufficient/conflicting → UNKNOWN. "spawn 0" single-source assertion is FORBIDDEN. - No backward state transitions (only forward or → UNKNOWN). - system_prompt path direct comparison — NO grep -v cokacdir filter (known bug). ) annotationsN)Optionalz4CHAIR-AUTH-TASK-2704-V36-CONTROL-PLANE-P0-MVP-260528NOT_REGISTERED REGISTEREDFIRED SESSION_SEEN WORK_STARTED ARTIFACT_SEENCALLBACK_REGISTEREDDONEUNKNOWNz/home/jay/workspacez memory/eventszmemory/task-timers.jsonz/home/jay/.cokacdirc t|||xst|xst|xstS#t$r}t id|ddcYd}~Sd}~wwxYw)aDetect the spawn state for task_id using multi-signal cross-validation. Returns: { "state": str, # 9-state enum value "signals": dict, # raw signal values "reason": str, # human-readable decision reason "signal_count": int, # number of positive signals observed } Never raises. Returns UNKNOWN on any internal error. )task_id schedule_id events_dir timers_filecokacdirz/detect_spawn_state internal error (safe-fail): rstatesignalsreason signal_countN)_detect_spawn_state_impl _EVENTS_DIR _TIMERS_FILE _COKACDIR Exceptionr )rrrrrexcs 9/home/jay/workspace/scripts/harness/v36/spawn_detector.pydetect_spawn_stater ?sa& '#!0[#3|*     GuM    s'* A  AA A c|tk(s |tk(rytj|dtj|dk\S)zReturn True if state_a is >= state_b in the progression order. UNKNOWN is treated as incomparable (returns False for any comparison). F)r _STATE_ORDINALget)state_astate_bs rstate_ger'cs; 'W/   gr *n.@.@".M MMcrtj}i}t||}||d<|dv|d<|s t||}||d<t||d<t jt j j||d}t|dkD|d<||d <d } |rCt j j|d |d } t j j| } | |d <t} d } d} t}|D]}|s|| k7s d} |} n| |d<| |d<| |d<t||}||d<|duxr|dk|d<t|||}||d<|duxr|dk|d<t jt j j||d}||d<t|dkD|d<t jt j j||d}t|dkD|d<d }|rBt j j||d}t j j|}||d<|dr|dvrtt|dt!|S|dr$|ds|dvrtt"|d t!|S|drtt$|d!t!|St'|d|d|d|g}|dr |d"k\rtt(|d#t!|S| r| rtt*|d$t!|S|r"| s|drtt,|d%t!|S|dr |drtt.|d&t!|S|d xr&|d xr|d xr|d xr|d xr|d }|rtt0|d't!|Stt2|d(t!|S))N timer_status)absent timer_presentrschedule_id_presentz .dispatched*rdispatch_marker_presentdispatch_marker_pathsFschedule_historyz.logschedule_history_presentTbot_session_activebot_session_hexanu_session_hexworktree_mtime_secondsiworktree_freshartifact_mtime_secondsartifact_freshz.done* done_markersdone_marker_presentz .callback-*callback_marker_presentz.outputbot_output_present) completed!completed_owner_decision_acceptedz%done_marker_present + timer completedz&callback_marker_present + done contextzrecent artifact mtime < 900sz+dispatch_marker + corroborating work signalz2bot_session_active with distinct system_prompt hexz1schedule_id + schedule_history or dispatch_markerz#timer_running + schedule_id_presentz>all key signals absent (timer, schedule_id, session, artifact)uasignals present but insufficient or conflicting for firm state determination — poll next sample)time_get_timer_status_get_schedule_id_from_timerboolglobospathjoinlenisfile_get_anu_session_hex_list_claude_processes_get_worktree_mtime_seconds_get_artifact_mtime_seconds_resultr _pos_countr r sumr rrrrr )rrrrrnowrr*dispatch_markersr1 history_pathr4r2r3 bot_processesproc_hexr5r7r9callback_markersr<bot_output_pathwork_started_signals key_absents rrros ))+CG%Wk:L*GN+;>GO 1';G (GM%)+%6G !"yyjWI\:R!ST),-=)>)BG %&'7G #$ %ww||H.@[MQUBVW #%77>>,#? *BG &'+,OO*,M! O3!% &O   %7G !!0G !0G 9#F(>G $% 6d B cG]`cGcG 9*cR(>G $% 6d B cG]`cGcG 99RWW\\* 6HIJL*GN%(%6%:G !"yyjWI[:Q!RS),-=)>)BG %&'',,xK=1HIWW^^O<$6G !$%,:l*ltW&MzZaObcc()%&,:l*l*G5]_ijq_rss }g/MzZaObcc)* !$%   ().Ba.G|W.[]gho]pqqo|W.bdnovdwxx0GB BBc& tjj|syt|d5}t j |}dddj di}||vry||j dS#1swY4xYw#t$rYywxYw)Nrbrcrerrhrls rrBrBs ww~~k* + 0 !B99R=D !"% % W~!!-00  ! ! s3B BA8B$B8B=B BBcdtjjdd}|r|S tdd5}|j j ddj dd }d d d d d l}|jd }|r|jd S y #1swY4xYw#t$rYy wxYw)zGet the hex identifier of the current ANU (orchestrator) session. Reads from the ANU_SESSION_HEX env var (set by the session itself), or attempts to identify from the CLAUDE_SESSION_ID / system_prompt path. Returns None if unavailable. ANU_SESSION_HEXz/proc/self/cmdlinerbrbreplaceerrors Nrsystem_prompt_([0-9a-f]{16})r]) rEenvironr$rireaddecodertresearchgroupr)env_hexrmcmdliner}ms rrJrJ&sjjnn.3G  & - Wggi&&wy&AII&RUVG W  II5w ? 771:    W W    s( B#2B$0B#B B## B/.B/cddl}g} tjdD]}|js d|d}t |d5}|j j dd jd d }dddd vrf|jd |}|r!|j|jdnd |vr|jd |S#1swY]xYw#ttf$rYwxYw#t$rY|SwxYw)uReturn list of system_prompt hex values for running claude processes. Uses direct /proc inspection. NO grep -v cokacdir filter (spec §1.1). Returns list of hex strings (may include None for processes without hex). rNz/procz/proc/z/cmdlinersrbrtrurwrxclauderyr])r}rElistdirisdigitrir{r|rtr~appendrPermissionErrorFileNotFoundErrorr)r}hexes pid_entry cmdline_pathrmrrs rrKrK@s  E G, I$$& !' {(; ,-_ ggi..wy.IQQRXZ]^G_7*II=wGLL,(LL& & L__$%67     L sY)C3C2C6 CC3A C C3C CC0-C3/C00C33 D?Dc` tjjtd}tjj |sytjj||d}t j |}|syt d|D}t||z S#t$rYywxYw)zEReturn seconds since last modification of any task worktree, or None.z .worktreesNz-*c3K|]C}tjj|s#tjj|EywNrErFexistsgetmtime.0ps r z._get_worktree_mtime_seconds..js/W1RWW^^TUEV277++A.W $A $A ) rErFrG _WORKSPACEisdirrDmaxintr)rrQworktrees_basepattern worktrees latest_mtimes rrLrL`s j,?ww}}^,'',,~'"~>IIg& W WW 3%&& sAB!:B!B!! B-,B-c tjj||d}tj|}|syt d|D}t ||z S#t $rYywxYw)zOReturn seconds since last modification of any task-related event file, or None.z.*Nc3K|]C}tjj|s#tjj|Eywrrrs rrz._get_artifact_mtime_seconds..ws/S1PQAR277++A.Sr)rErFrGrDrrr)rrrQrfilesrs rrMrMpsg'',,zgYb>: '"SSS 3%&& s:AA A)(A))NNNN) rstrr Optional[str]rrrrrrreturndict)r%rr&rrrC) rrrrrrrrrrrr) rrrrrrrrrr)rrrr)rrrrrr)rrrrrr)rr)rzlist[Optional[str]])rrrQfloatr Optional[int])rrrrrQrrr)(__doc__ __future__rrDrjrE subprocessr@typingrCHAIR_AUTHORIZATION_IDrrrrr r r r r _STATE_ORDER enumerater#rrFrGrrrr r'rrNrOrArBrJrKrLrM)iss00rrs"#  O"     +     $-\#:;41a!Q$; " ggll:7 ww||J(AB ! "& $!%" ! ! ! !  !  !  ! HNF FFF F  F  FR  4@  w