'jUdZddlmZddlZddlZddlmZddlmZmZddl m Z ddl m Z m Z ejeZdZd ed <d Zd ed <e j(d z dz Zded<e dZd"dZd#dZd$dZedGddZed d%dZ d&deed d'dZddeed d(dZdded d)d Zgd!Zy)*u~utils/schedule_id_freshness.py — task-2535 P0 (신호등 sync fix C). 회장 명시 (2026-05-10): 자동머지 시그널 (특히 schedule_id) 신선도 검증 부재. 오래된 cron schedule_id로 잘못된 활성 판정 가능. ★ Fix C: schedule_id freshness validator — heartbeat / staleness threshold 명시. 3 freshness states: FRESH — schedule_id 응답 ts가 SCHEDULE_FRESHNESS_THRESHOLD_MIN 이내 STALE — 마지막 응답 ts가 임계 초과 (cron schedule가 살아있는 것처럼 보이지만 무응답) MISSING — schedule_history/{ID}.log 부재 또는 chat=6937032012 record 0건 회장 §명시 격리: schedule_history 폴더는 모든 chat 공유. 회장 chat (CHAIRMAN_CHAT_ID = 6937032012) 레코드만 사용. 다른 chat record는 silently skip (cokacdir docs § isolation 정합). 회장 §금지: - ❌ 다른 chat record를 freshness 판정에 사용 - ❌ token / raw key / response 본문을 dict에 그대로 노출 - ❌ schedule_history 폴더 외부 IO (파일 쓰기 / 다른 path 읽기) - ❌ utils/lifecycle_reconciliation_manager.py 외 다른 영역 stuck case 수정 ) annotationsN) dataclass)datetimetimezone)Path)LiteralOptional<int SCHEDULE_FRESHNESS_THRESHOLD_MINlL5:CHAIRMAN_CHAT_IDz .cokacdirschedule_historyrDEFAULT_SCHEDULE_HISTORY_DIR)FRESHSTALEMISSINGc&|xst}||dz S)Nz.log)r) schedule_id history_dirbases 2/home/jay/workspace/utils/schedule_id_freshness.py_resolve_log_pathr7s  66D [M& &&c t|tr|sy|j}|jdr|dddz} t j |}|j |jtj}|S#t $rYywxYw)uPschedule_history JSONL 의 'ts' 필드를 datetime(timezone-aware)으로 변환.NZz+00:00tzinfo) isinstancestrstripendswithr fromisoformat ValueErrorrreplacerutc)ts_valuerawdts r _parse_tsr*<s h $H .. C ||C#2h!  # #C ( yy ZZx||Z , I sB B  B c|#tjtjS|j |j tjS|S)Nr)rnowrr&rr%)r,s r _coerce_nowr-Ms> {||HLL)) zz{{(,,{// JrT)frozenc"eZdZUded<ded<y) _LastRecordrtsr chat_idN)__name__ __module__ __qualname____annotations__rrr0r0Us L Lrr0chairman_chat_idc|jsyd} |jdd5}|D]}|j}|s tj|}t |ts=|jd} | t|nd}|||k7rft|jd} | || |jkDst| |} ddd|S#tj $rYwxYw#ttf$rd}Y}wxYw#1swY|SxYw#t$r!} t j#d|| Yd} ~ yd} ~ wwxYw) ugschedule_history/{ID}.log 에서 chat=chairman 인 마지막 record 추출. 회장 §격리: chat_id 가 chairman 이 아닌 record 는 모두 skip (다른 chat 소유). 파일 부재 / 파싱 실패 / chairman record 0건 → None 반환. token / response 본문은 절대 dict 에 담아 반환하지 않는다 — ts / chat_id 만 노출. Nzutf-8r%)encodingerrorsr2r1)r1r2z%schedule_history read failed: %s (%s))existsopenr!jsonloadsJSONDecodeErrorrdictgetr TypeErrorr$r*r1r0OSErrorloggerwarning) log_pathr9lastfhraw_linelinerecord chat_valuechat_intts_dtexcs r_read_last_chairman_recordrR[sX ?? "&D ]]GI] > C" C~~'!ZZ-F"&$/#ZZ 2 $2<2Hs:dH#x3C'C!&**T"23=<5477?&%BD/ C C: K-++":.$#H$ C: K >#NsDD C"D :C3 6D D DC0-D /C00D 3DD DD  DDD E D<<E)r threshold_minr9c0t|||||}|dk(|fS)uschedule_id 의 freshness 를 판정한다. return: (is_fresh, reason_token) - reason_token ∈ {"FRESH", "STALE", "MISSING"} (classify_freshness 와 정합) - is_fresh = (reason_token == "FRESH") 회장 §명시: ts_age = now - last_chairman_record.ts threshold = SCHEDULE_FRESHNESS_THRESHOLD_MIN (60분) ts_age < threshold → FRESH, 그 외 → STALE log 부재 / chairman record 0건 → MISSING r,rrSr9r)classify_freshness)rr,rrSr9states ris_schedule_id_freshrXs/(  #)  E W u $$rrUc|syt||}t||}|yt|}||jz j }t dt |dz} || kryy)u3 상태 분류 — FRESH / STALE / MISSING. 회장 §명시 freshness 판정 단일 진입점. lifecycle_reconciliation_manager 에서 STALE_SCHEDULE_ID stuck case 분류용으로 사용. rr8rgN@rr)rrRr-r1 total_secondsmaxr ) rr,rrSr9rHrInow_dt age_secondsthreshold_secondss rrVrVsr  k:H %hAQ RD |  FDGG#224KAs=12T9&& r)r,rr9c|syt||}t||}|yt|}||jz j S)u마지막 chairman record 로부터 경과 초 수. log 없으면 None. lifecycle_reconciliation_manager evidence 첨부용 (detail 메시지에서 사용). Nr8)rrRr-r1rZ)rr,rr9rHrIr\s rschedule_id_age_secondsr`sM  k:H %hAQ RD |  F TWW  + + --r)r r rFreshnessStaterXrVr`)rr rOptional[Path]returnr)r'objectrcOptional[datetime])r,rercr)rHrr9r rczOptional[_LastRecord])N) rr r,rerrbrSr r9r rcztuple[bool, str]) rr r,rerrbrSr r9r rcra) rr r,rerrbr9r rczOptional[float]) __doc__ __future__rr?logging dataclassesrrrpathlibrtypingrr getLoggerr3rFr r6r homerrarr*r-r0rRrXrVr`__all__r7rrros,# !'$   8 $)+ #*##"&/TYY[;%>AS%SdS45' " $-... .n#%#'9, %% % %  %  %%B#"&9,       <#"&, .. . .  .  .* r