-ǚjUdZddlmZddlZddlZddlZddlmZmZm Z m Z m Z m Z ejeZdZdZdZdZd Zd Zd Zd Zd ZdZdZdZeefZdddd#dZdddd#dZdddd$dZdd d%dZ d&dd d'dZ! d&dd d(dZ"dZ#d)dZ$dd d*dZ% d& d+dZ& d&dddd d,d Z' d-d!Z( d.d"Z)y)/u8앞 화 명부를 추출에 실어 **같은 것을 같은 신원으로** 잇는다. ## 왜 번호를 프로젝트 장부에서 발급하면(`app.core.entity_identity`) 2화가 1화를 **덮는 일**은 없어진다. 그러나 같은 인물이 화마다 **새 번호**를 받는다 — 실측 `da049582` 에서 같은 사람이 `C02 기사 최씨`(3화)와 `C06 최씨`(2화)로 두 행이 됐다. 이어 붙이려면 추출하는 모델이 앞 화를 **봐야** 한다. ## 계약 (Codex 2026-09-04 합의) 1. 모델은 **명부에서 고르거나** 「새것」이라고만 답한다. 임의의 `short_id` 를 쓰지 못한다 — 허용 목록이 **그 호출에 실린 명부**의 runtime enum 이다. 2. 서버가 대조한다. 명부 밖 값은 인정하지 않고 **새것**으로 돌린다. 3. 두 행이 같은 기존 ID 를 주장하면 **둘 다 새것**이다(fail-closed). ★잘못 쪼개는 편이 잘못 합치는 것보다 안전하다 — 합치면 앞 화의 그림과 설명이 남의 것이 되는데, 쪼개면 행이 하나 늘 뿐이다. 4. 명부에는 이름만이 아니라 **별명**(`EntityAlias`)과 **구조 앵커**를 싣는다. ★지금 앵커가 있는 갈래는 **아웃룩(입는 인물)뿐**이다. `location_part` 는 이 판의 이관 대상이 아니라 앵커를 안 만든다 — 대상으로 넓힐 때 같이 만든다. 5. 지시문은 **팩**에서 온다. 소스에 박으면 버전도 hash 도 audit 도 없다. ★명부가 비면(첫 화) 이 모듈은 **한 바이트도 안 바꾼다** — 스키마도, 프롬프트도. ) annotationsN)AnyDictListOptionalSequenceTupleepisode_carry_ledgerprior_short_idNEWreusednewrejected contested episode_carryz1.202609040000prior_roster_headprior_roster_ruledbversionc Lddlm}|xst}tDcic]}||t|d||}}dj dt |jD}t||tj|jdjdd d Scc}w) uL명부 지문 팩. `raw_content_hash` 를 소비 지문에 접어야 한다.r)resolve_effectiveprompt)kindrr|c 3NK|]\}}|d|dd|dd|dyw):sourcerraw_content_hashN).0strs X/Users/manta/Documents/Projects/TheRoad-I1/backend/app/modules/pipeline/episode_carry.py zload_pack..CsB/-EB $a( }Aa l^1Q/A-B,CD-s#%utf-8N)modulerstemspack_manifest_hash) app.modules.prompt_loaderrPROMPT_PACK_VERSIONSTEMS_MODULEjoinsorteditemshashlibsha256encode hexdigest)rrrverr#resolvedmanifests r% load_packr:<s;  ((CDIKDIb%gr.1b::DI Kxx/HNN,-//H#")..(#**3)+cr#; << KsB!c<t||}t|d|ddS)u`소비 지문에 접을 좌표. ★상수만 올리고 bytes 를 안 접으면 안 움직인다.rrr+)carry_contract carry_packcarry_pack_hash)r:CARRY_CONTRACT_VERSION)rrpacks r%pack_fingerprintrAKs+ G ,D4y/#$89 ;;c.t||d|dS)Nrr*content)r:)stemrrs r%_textrFSs G ,W 5d ;I FFrBF include_selfcddlm}ddlm}ddlm}|j |d|rdndzdz||d jDcgc]}|d }}|sgS|j|j|j|k(j} i} g} | D]K}|j| j|!| j|jgj|Mi} |D]z} | j| xsg}|r|D]}|| |j <1| s4t#|||| }| D]/}|j$|vs|j&|vs!|| |j <1|t)| j+Scc}w) uC명부 앵커가 볼 **배정 범위** — 앞선 화수 + 이 화, **화별로** 판정. ★★★소비자용 `episode_outlook_rows`(정확히 이 화)와 **다른 물음**이다 (Codex BLOCK 2026-09-04 3차). 명부에는 앞 화 canon 이 실린다. 그런데 앵커를 「이 화의 배정」으로만 보면, **2화를 처음 추출할 때는 2화 아웃룩 배정이 아직 없어서** 1화의 `O01` 이 명부에 나오면서도 착용자가 비어 버린다 — 같은 이름의 옷을 가르는 핵심 정보가 사라진다. 반대로 프로젝트 전체를 보면 **미래 화의 착용자**가 섞인다. 그래서 범위는 명부와 **똑같이** 「앞선 화수 + 이 화」다. ★★★그리고 exact-first 는 **화마다** 따진다 (Codex BLOCK 4차). 범위 전체로 한 번에 접으면 — 014 뒤 2화만 sync 돼 exact 가 생기고 1화는 아직 NULL 인 **흔한 중간 상태**에서, 3화 명부가 **1화 앵커를 통째로 잃는다.** legacy 판정의 「양 끝이 걸렸나」도 **그 화의** active 집합으로 본다. 화들을 합쳐 보면 `C01` 은 1화에만, `O02` 는 2화에만 active 인데도 「범위 안에 둘 다 있다」로 통과한다 — **같은 화에서 함께 active 였다는 근거가 없다.** rtext)active_episode_canon_ids)CharacterOutlookz:SELECT e.id FROM episode e WHERE e.project_id = :pid AND (z e.id = :eid OR zh e.episode_number < ( SELECT episode_number FROM episode WHERE id = :eid)) ORDER BY e.episode_number)pideid) sqlalchemyrKapp.core.entity_identityrLapp.models.projectrMexecutefetchallqueryfilter project_idall episode_idappend setdefaultgetidset character_id outlook_idlistvalues)rrXrZrHsql_textrLrMr$eligiblerowsby_eplegacyoutrPexactactives r%_carry_anchor_rowsrlWs0,A3 !jjD". B 8 $ $* *- / 08xz :;:!:H;  88$ % , ,##z1 33635 "$EF  <<  MM!    Q\\2 . 5 5a 8  C #$" ADD   -b*cBCA~~'ALLF,BADD   E;s Fc |r|dk7s|siSt|}t||||Dcgc]}|j|vr|}}|siSddlm} |j | ddt |Dchc]}|jc}ijDcic] }|d|d } }i} |D]K}| j|j} | s!| j|jgj| M| jD cic])\} }| djt t|+c}} Scc}wcc}wcc}wcc}} w) u구조 앵커 — 그 행이 **무엇에 매달려 있는가**. ★같은 이름이 여러 개일 때 이것 하나로 갈린다. ★지금 구현된 갈래는 **아웃룩뿐**(입는 인물). 다른 갈래는 빈 값이고, 그것이 계약이다 — 있는 척하면 다음 사람이 앵커를 믿고 합친다. ★범위는 `_carry_anchor_rows` 가 정한다 — 명부와 **같은 범위**여야 앞 화 착용자는 남고 미래 화 착용자는 안 섞인다. outlookrGrrJzSSELECT id, short_id FROM entity_canon WHERE id = ANY(:ids) AND short_id IS NOT NULLidsr ·)r_rlrarQrKrTr1r`rUr]r\r[r2r0)rrXowner canon_idsrZrHwantr$rfrd short_by_idrisidkvs r% _anchor_forrxsp ** y>D)"j*7CE %E!||t# ED %  +JJx <(  6484a1>>489 :<=EHJGGq!ad G !#C ooann-  NN1<< , 3 3C 869YY[ A[TQAtyyA( ([ AA% %9  BsD?'EE  .Ec ddlm}ddlm}|r5|j |d|rdndzdz|||dj }n)|j |d ||d j }|Dcgc] }|d |k7s |}}|sggfS|Dcgc]}|d } }|j |d d | ij } i} | D]&\} } | j | gj| (t|||| ||}g}g}|D]\} }}}|j|d|d|g}| j| }|r5|jddjtt||j| }|r|jd|djt|j}|r|j|dd|jdj|||fScc}wcc}w)u**앞 화들**(그리고 force 일 때만 이 화 자신)의 신원 목록. ★★★``episode_id`` 를 주면 **앞선 화수**의 것만 싣는다 (Codex BLOCK 2026-09-04). 프로젝트 전체를 실으면 1화를 다시 분석할 때 2·3화 신원이 **과거로 새어** 들어가고, 어느 화에도 안 붙은 고아까지 후보가 된다. ★``episode_id`` 를 안 주면 예전처럼 프로젝트 전체다 — 도구·조회용이다. ★★★``include_self`` — **이 화 자신**을 넣을지 (2026-09-04 실측 수정). 넣는 까닭: 같은 화를 `force` 로 다시 돌릴 때 모델이 제 앞 판 산출을 못 보면 전부 「새것」이 되어 **재실행마다 번호가 늘어나고**, 뒤 화가 이미 가리키던 옛 번호와 **같은 사람이 둘로 갈린다**. 그런데 늘 넣으면 명부 내용이 **언제 처음 얼리느냐**에 따라 달라진다. 이 화가 아직 안 돌았으면 비어 있고, 돌고 난 뒤 처음 물으면 제 canon 이 들어찬다. 그러면 이 PR 이전에 **이미 분석된 화**는 재개할 때마다 지문이 어긋나 `entity_all_*` 과 `outlook_phase1` 을 **다시 산다** (실측: 1화 재개가 10초 만에 `config_hash mismatch` 로 섰다). 그래서 **force 로 스냅샷을 다시 뜰 때만** 넣는다. 그 자리에서는 이 화가 이미 돈 것이 확실하고, 어차피 다시 사는 판이라 지문이 움직여도 손해가 없다. 평상시 경로는 앞 화만 보므로 **얼리는 시점과 무관**하다. Returns: (프롬프트 줄들, 허용 `short_id` 목록). 없으면 **둘 다 비었다** — 그러면 첫 화는 한 바이트도 안 달라진다. rrJ)NULL_OUTLOOK_SHORT_IDa SELECT DISTINCT c.id, c.short_id, c.name, COALESCE(c.description, '') FROM entity_canon c JOIN entity_episode_link l ON l.canon_id = c.id JOIN episode e ON e.id = l.episode_id WHERE c.project_id = :pid AND c.entity_type = :et AND c.short_id IS NOT NULL AND (ze.id = :eid OR rNzj e.episode_number < ( SELECT episode_number FROM episode WHERE id = :eid)) ORDER BY c.short_id)rOetrPzSELECT id, short_id, name, COALESCE(description, '') FROM entity_canon WHERE project_id = :pid AND entity_type = :et AND short_id IS NOT NULL ORDER BY short_id)rOr{r zCSELECT canon_id, alias FROM entity_alias WHERE canon_id = ANY(:ids)rorGz- z | u다른 이름: z, u 딸린 곳:  Nx)rQrKrRrzrTrUr\r[rxr]r0r1r_strsplit)rrXrqrZrHrdrzrfr$ro alias_rowsaliasescidaliasanchorslinesallowedrunamedescpartsaltancones r%build_prior_rosterrs:>,>zz( /;* D " "  U: > @AI  zz(  U + - .6XZ  =t!qt'<? > s1 G>?G> Hz_carry_snapshot.jsoncrddl}ddlm}|j|j|z dz dz |z t z S)Nr)settings checkpointsepisodes)pathlibapp.core.configrPath projects_dir SNAPSHOT_NAME)rXrZ_plrs r%_snapshot_pathr sA( HHX** +j 8= H % &(5 67rBrefreshc ddl}t||}i}|jr" |j|j d}||vr|s||} t| tr>t| jdtrt| jd tst d |d |d | d rGtjd j| djdjddnd} | jd| k7r't d|d |d| jdd| d | St!|||||\} } | | | rDtjd j| jdjddndd} | ||<ddlm}|j&j)dd|||| S#t $r}t d|d|d|d}~wwxYw)u이 화가 쓰는 명부 — **한 번 얼리면 안 바뀐다**. ★★★왜 얼리나 (Codex BLOCK 2026-09-04 재지적). 명부를 매번 현재 DB 에서 읽으면, **이 화가 제 canon 을 만든 뒤** 명부가 달라진다. 그러면 같은 체크포인트의 지문이 스스로 어긋나서 **재개가 유료 상류를 다시 산다.** 무료 스텝의 지문 어긋남이 유료 하류를 다시 사는 부류다. 그래서 이 화가 **처음 물을 때** 얼려 파일로 남기고, 그 뒤로는 그것만 본다. `refresh=True`(force 재실행)일 때만 다시 뜬다. Returns: ``{"lines": [...], "allowed": [...], "digest": "..."}`` rNr')encodingu.이 화의 명부 스냅샷을 못 읽는다: z (u5). 고치거나 지운 뒤 force 로 다시 돌려라rru)명부 스냅샷의 모양이 깨졌다: z (owner=u(). 지운 뒤 force 로 다시 돌려라 r(rNdigestu7명부 스냅샷의 지문이 내용과 안 맞는다: u , 적힌 것=u , 계산=)rG)rrr)atomic_write_jsonT)parentsexist_ok)jsonris_fileloads read_text Exception RuntimeError isinstancedictr]rbr3r4r0r5r6rapp.core.checkpoint_iorparentmkdir)rrXrZrqr_jsonpathdataexcgotrsrrentryrs r%carry_snapshotr)s  *j 1DD ||~ C;;t~~w~?@D  }W5k3%!#'''"2D9!#'')"4d;;D6%Q89: :&)^tyyW6==gFGSb"9; 778  $I$P cggh.?-B)D8STVW W (Jz5<>NE7-4 tyy'7'>'>w'GH"Sb*:< ?EDK9KKdT2dD! LI C@bN89:?B C Cs!G G.G))G.c|sXt|||\}}|rDtjdj|j dj ddSdSt ||||dS)u이 화가 **실제로 보는 명부**의 지문. 없으면 빈 문자열. ★★팩 버전만 접으면 명부 **내용**(이름·별명·앵커)이 바뀌어도 지문이 안 움직여 옛 체크포인트가 그대로 재사용된다 (Codex BLOCK 2026-09-04). ★반대로 프로젝트 전체를 접으면 뒤 화가 생길 때마다 앞 화가 제 것이 아닌 변화로 계속 stale 된다 — 그래서 **앞 화 + 이 화** 범위와 같아야 한다. rr'Nr(rNr)rr3r4r0r5r6r)rrXrqrZrrs r% roster_digestrgss +B EBwtyy/66w?@JJLSbQ $ " $ "j*e > @D w 8 > > @D 99dB111D1 2D D=' !!rBc|s|Stj|}g|t}t|j dij D]w}|d|}|j ddk7sd|vr$|dj di}|dj dg}d|d|t<t|vsc|jty|S)u산출에 **`prior_short_id` runtime enum** 을 더한다. ★허용 목록은 **그 호출에 실린 명부** + `NEW` 뿐이다. 팩에 안 박는다. ★`allowed` 가 비면 스키마를 안 건드린다 — 첫 화 불변. propertiestypearrayr2requiredstring)renum) copydeepcopy NEW_SENTINELrbr]keysr\FIELDr[)schemarrirkeyarrpropsreqs r%patch_schema_with_prior_idsrs  -- C #W #l #DCGGL"-2245,$ 776?g %); G '' b9'l%%j"5 ($7e   JJu 6 JrBct|}i}tdtdtdtdi}|s4|D]}|j t dt||t<||dSi}t|D]\}}t|jt xsdj}|r |tk(rB||vr7t|d|d|<|txxdz cc<tjd|}|j|gj!||j#D]s\} } t| dkDr;t|| <|txxdz cc<tjd | t| O| || dd <t|| <|txxdz cc<u|D]V}|j t dt|jd xsdjrF|txxdz cc<X||dS) u모델이 고른 앞 화 신원을 **대조해서** 행에 옮긴다. - 명부 안의 값 → 그 행의 `short_id` 가 된다(물려받음). - 명부 밖 · `NEW` · 빈 값 → 그대로 두어 발급기가 새 번호를 준다. - 같은 ID 를 **둘 이상**이 주장 → **모두** 새것 (fail-closed). Returns: 장부 — `{short_id or index: 행선지}` 와 갈래별 개수. ★계산해 놓고 안 남기면 「다퉜다」와 「원래 새것」이 구별이 안 된다. rN)ledgercountsrN#rr uHepisode_carry: 명부에 없는 앞 화 ID %r — 새것으로 돌린다ucepisode_carry: %s 를 %d 행이 주장 — 합치지 않고 모두 새것으로 둔다(fail-closed)short_id)r_ CARRY_REUSED CARRY_NEWCARRY_REJECTEDCARRY_CONTESTEDpoprlen enumerater~r]rrloggerwarningr\r[r2) entitiesrallowrreclaimsirawruidxss r%apply_prior_idsrs LEFAy!a!5F A EE% My F33$&F(#1!%%,$"%++-c\)  e $2FQqc3%= ! > "a ' " NNZ\_ a #r"))!,$\\^ T t9q=)F3K ? #q ( # NN&'*CI 7 (+a*%"s |!$ eT155$*+113 9  "  //rB)r Optional[str]returnDict[str, Any])rEr~rrrr~)rXr~rZr~rHboolrz List[Any])N) rXr~rqr~rr Sequence[str]rZrrHrrzDict[str, str]) rXr~rqr~rZrrHrrzTuple[List[str], List[str]])rXr~rZr~) rXr~rZr~rqr~rrrr)rXr~rqr~rZrrr~) rXr~rqr~rZrrrrrrzTuple[str, List[str]])rrrrrr)rzSequence[Dict[str, Any]]rrrr)*__doc__ __future__rrr3loggingtypingrrrrrr getLogger__name__r LEDGER_KEYr?rrrrrrr/r-rrr.r:rArFrlrxrrrrrrrrr!rBr%rs 0# ==   8 $$      &   I4 < $; $G -2B%)B6?BN-1!B&+!B(!B)!B#!B0>!BJBFYYY #Y1>YY!Yz' 7$); ;-;;~/3G+G7:G$BF"4$"" #"1>" "2?"",)6;I.60&601>6060rB