MjK4PdZddlmZddlmZmZddlmZddlm Z m Z m Z ddl m Z mZmZdZdZd Zd Zd Zd Zed GddZed GddZddZddZeedddd ddZeedddd ddZd dZd!dZgdZy)"umutils.dispatch_spawn_verifier — task-2645 spawn verification gate. 회장 verbatim (2026-05-24 task-2644 사고 박제 §17.11): spawn verification 은 4 항목으로 구성된다. 1) workspace dir 존재 : ``/home/jay/.cokacdir/workspace//`` 가 생성됐는가 2) executor process or first activity signal : ``ps -ef | grep claude`` 또는 workspace dir 내부 활동 흔적 (파일/디렉토리 ≥1) 3) schedule visibility OR schedule accepted marker : cron-list 에 노출되거나 1회성 자동삭제 schedule 의 경우 ``schedule_history`` 에 accepted marker 4) schedule_history 부재 = 3 상태 분리 (in-progress / 종료 / silent drop) 단독 "log 미존재" 단정 금지 — 다른 신호와 교차 판정 silent drop 확정 조건 (회장 verbatim 4신호 모두 hit): - workspace dir 빈 채 (생성됐어도 활동 0) - schedule_history log 부재 - 봇 process 없음 - cron-list 0 개 본 모듈은 가급적 stdlib 만 사용 + pure helper. dispatch.py / regression 양쪽에서 공유 가능하도록 dataclass 결과 + JSON dump 인터페이스를 제공한다. ) annotations) dataclassfield)Path)ListOptionalSequence)DISPATCH_SILENT_DROP_HOLDDISPATCH_SUBMITTED_UNVERIFIEDDISPATCH_VERIFIED_SPAWNz/home/jay/.cokacdir/workspacez$/home/jay/.cokacdir/schedule_historyHISTORY_ABSENT_IN_PROGRESSHISTORY_ABSENT_AFTER_COMPLETIONHISTORY_ABSENT_SILENT_DROPHISTORY_PRESENTT)frozencVeZdZUdZded<ded<ded<ded<ded<ded<d d Zy ) SpawnSignalsu8spawn verifier 입력 신호 (회장 verbatim 4 항목).boolworkspace_dir_existsworkspace_dir_has_activityexecutor_process_presentschedule_visible_in_cron_list schedule_accepted_marker_presentschedule_history_log_presentc|j|j|j|j|j|j dS)Nrrrrrrrselfs N/home/jay/workspace/.worktrees/task-2645-dev2/utils/dispatch_spawn_verifier.pyto_jsonzSpawnSignals.to_json;sB$($=$=*.*I*I(,(E(E-1-O-O040U0U,0,M,M   Nreturndict)__name__ __module__ __qualname____doc____annotations__r r!rrr0s.B $$""#''&**"&& r!rcreZdZUdZded<ded<ded<ded<ded <ded <ee Zd ed <ddZy)SpawnVerificationResultu+spawn 확인 결과 + 천이 후보 status.strcron_idrsignalsrverified silent_drop history_state next_status)default_factoryz List[str]reasonsc d|j|jj|j|j|j |j t|jdS)Nz%dispatch.spawn_verification_result.v1)schemar.r/r0r1r2r3r5) r.r/r r0r1r2r3listr5rs rr zSpawnVerificationResult.to_jsonRsT=||||++- ++!//++DLL)  r!Nr") r%r&r'r(r)rr8r5r r*r!rr,r,Fs;5 L Nt4GY4  r!r,c|jrtS|jr|jrtS|js|jst S|j r|jstStS)uschedule_history 부재의 3 상태 분리 판정. 회장 verbatim: "schedule_history 부재는 작업 중/종료 후/미발사(silent drop) 로 분리 판정 — 단독 'log 미존재' 단정 금지". 교차 신호: - log present => HISTORY_PRESENT - log absent + workspace activity + executor process => IN_PROGRESS - log absent + workspace dir exists + no activity + no proc => SILENT_DROP candidate - log absent + cron 비가시 + workspace 부재 => SILENT_DROP candidate - log absent + 부분적 신호 => AFTER_COMPLETION (1회성 자동삭제 마커 hit 면 종료 후로 본다) ) rrrrr rrrr)r/s r_classify_history_stater:_sa++))g.N.N))  . .00))//8]8].. **r!c g}t|}|j xs |j }|j }|j }|j xr |j }|xr |xr|xr|}|r'|jdt||dd|t|S|js |jrU|jd|jrdndz|jr|jdt||dd|t|S|jd |j r|jd |j r|jd t||dd|t|S) u:4 항목 + 4신호 silent drop 판정. silent drop 확정 (회장 verbatim) — 4신호 모두 hit: ① workspace dir 빈 채 (exists True + activity False) ← 또는 exists False ② schedule_history log 부재 ③ 봇 process 없음 ④ cron-list 0 개 (visible False) 또는 accepted marker 부재 위 4 신호 동시 hit ⇒ DISPATCH_SILENT_DROP_HOLD. workspace 활동 또는 executor process ≥1 hit ⇒ DISPATCH_VERIFIED_SPAWN. 그 외 (부분 신호 + 판정 보류) ⇒ DISPATCH_SUBMITTED_UNVERIFIED (재폴링). usilent drop 확정: workspace 빈 채 + history log 부재 + executor process 부재 + cron 비가시/accepted marker 부재 — 4신호 모두 hit.FT)r.r/r0r1r2r3r5zspawn verified: zworkspace activity hitzexecutor process hitu%schedule_history log present (보강)u_verification 부족: 활동/process 신호 둘 다 0 — submitted_unverified 재폴링 필요.u*cron-list 가시 — 발사 직후 가능.u/schedule accepted marker hit — 등록 인정.) r:rrrrrrappendr,r r r ) r.r/r5r2workspace_emptyhistory_absent no_process not_listedr1s revaluate_signalsrA~sG+G4M#777dAcAc=cO ===N555J  1 11 988 8 "RnRR K N ''1  ))W-M-M 55)+     / / NNB C&'/   NNi,,CD//HI "#1 r!Nworkspace_rootschedule_history_root cron_list_idsexecutor_process_idsaccepted_marker_idscft||z }|j}d}|r t|j}t||dz } | j } t |xr||v} t |xr||v} t |xr||v} t||| | | | S#t$rd}YrwxYw)uZlive 파일시스템 (옵션) + caller 제공 정보로 신호 수집. Pure 함수가 아닌 부분: workspace_root / schedule_history_root 디렉토리를 stat. caller 가 의존성을 모두 주입하면 (모든 인자 명시) 순수 함수처럼 동작 — regression fixture 에서 그대로 활용 가능. Args: cron_id: cokacdir cron schedule id (예: ``"673AA5A6"``). workspace_root: cokacdir workspace 루트 디렉토리. schedule_history_root: schedule_history 루트 디렉토리. cron_list_ids: ``cokacdir --cron-list`` 결과의 id 목록. None 이면 측정 불가 로 보고 visible=False 처리. executor_process_ids: cron_id 와 매칭되는 process id 목록 (외부 수집). accepted_marker_ids: 1회성 자동삭제 schedule 의 accepted marker id 목록. Fz.logr)ris_diranyiterdirOSErroris_filerr)r.rCrDrErFrGws_dirrrhist_logrrschedule_visibleaccepted_marker_presents rcollect_signalsrRs0. !G +F!==?!& /),V^^-=)> &)*y-==H#+#3#3#5 #$89_wJ^?^M*I=0H"#67\WH[=[ 1#=!9&6)@%A   /). & /sB"" B0/B0c<t||||||}t||S)u*signal 수집 + 평가 합성 entry-point.rB)rRrA)r.rCrDrErFrGr/s r verify_spawnrTs/%3#1/ G GW --r!cD|jxr|jtk(S)u;silent drop 확정 여부 — 회장 보고 hold 게이트.)r1r3r )results ris_silent_drop_confirmedrWs    Q&"4"48Q"QQr!cpt|tsy|jd}|tk(ry|dk(rd|vryy)uE``dispatch.py`` 반환 dict 가 SUBMITTED_UNVERIFIED 단계인지 확인. 회장 verbatim ANCHOR-1: cron_response.status="ok" 만으로 final success 보지 않는다. legacy dict {"status": "dispatched", "cron_response": {"status":"ok",...}} 도 spawn verification 전까지는 UNVERIFIED 로 간주한다. FstatusT dispatchedspawn_verification) isinstancer$getr )dispatched_dictrYs rdispatched_dict_is_unverifiedr_sC ot ,   *F ..   6 r!) COKACDIR_WORKSPACE_ROOT_DEFAULTSCHEDULE_HISTORY_ROOT_DEFAULTrr rrrr,rArRrTrWr_)r/rr#r-)r.r-r/rr#r,)r.r-rCr-rDr-rEOptional[Sequence[str]]rFrbrGrbr#r)r.r-rCr-rDr-rErbrFrbrGrbr#r,)rVr,r#r)r^objectr#r)r( __future__r dataclassesrrpathlibrtypingrrr utils.dispatch_status_enumr r r r`rar rrrrr,r:rArRrTrWr___all__r*r!rrjs\,#(++#B F:"C9# $   * $   0+>Pn:!>-14837/ // / + / 2 /1//j:!>-14837. .. . + . 2 .1..*R & r!