jU d Z ddlZddlZddlmZmZ ddlmZ ddlm Z ddl
m Z ej e
Ze G d d Zd
d ed
ed efd Zy)uH 기획서 분석 결과를 파이프라인 step 프롬프트에 주입하는 헬퍼.
사용법:
from app.core.planning_doc_context import get_planning_context
ctx = get_planning_context(project_id, episode_id, self.db)
if ctx.characters_text:
prompt += f"
## 기획서 인물 정보
{ctx.characters_text}"
N) dataclassfield)Path)Optional)settingsc e Zd ZU dZdZeed< dZeed< dZe ed< dZ
e ed< dZ e ed< dZ e ed < dZ
e ed
< dZe ed < dZe ed < ee
Zeed< dde de de fdZy)PlanningContextu8 기획서에서 추출된 주입 가능한 컨텍스트.Fhas_planning_docis_first_episode characters_textlocations_text
world_setting tone_mood story_arcvisual_conceptsrelationships_text)default_factoryavailable_sectionssectionheaderreturnc |dk( r
| j sy|dk( r
| j syt | |d }|sy|xs d| }d| d| dS )u 섹션이 있으면 헤더+내용 반환, 없으면 빈 문자열.
첫 에피소드만 주입하는 섹션(characters)은 is_first_episode 체크.
r
r r u ## 기획서 참고: z
z
z
)r getattr)selfr r valhdrs S/Users/manta/Documents/Projects/TheRoad-I1/backend/app/core/planning_doc_context.pyinject_if_availablez#PlanningContext.inject_if_available) sq ' '0E0E * *43H3HdGR(9/y93% )),-H
J
N)r )__name__
__module__ __qualname____doc__r
bool__annotations__r r
strr r r r r r r listr r r r r r s B "d" "d" OS NC M3IsIs OS %T ::
3
S
r r
project_id
episode_idr c h t }ddlm} || | }|t t j
| z dz dz }d}||z dz dz }|j
r|}nJ|j
r:t |j D ] } | dz dz }
|
j
s |
} n ||S t j |j d
} t | t r| j# d | nd}t |t s|S |j# d
g }
|
s|S d|_ |
|_ ddlm} d}|ddlm} | }d} |j1 | j3 |j4 | k( j7 |j8 j; }|r|d j< |k( rd|_ |r|jA |j# dg }|rd|
v rg }|D ] }d|d dg}|j# d r|jC d|d d |j# d r|jC d|d d |jC d |d |j# d r|jC d |d |jC d jE | d!jE | |_# |j# d"g }|r|d"|
v rxg }|D ][ }d|d dd |d g}|j# d r|jC d |d |jC d jE | ] d!jE | |_$ d#|
v r|j# d#d$ |_% d%|
v r|j# d%d$ |_& d&|
v r|j# d&d$ |_' d'|
v r|j# d'd$ |_( |j# d(g }|r!d(|
v r d!jE d) |D |_) |S # t $ r"} t j d | |cY d} ~ S d} ~ ww xY w# |r|jA w w xY w)*u 프로젝트의 기획서 분석 체크포인트를 로드하여 PlanningContext 반환.
Lookup 순서:
1. project-level: ``planning_doc_analysis_service.load_project_checkpoint``
(L4 source_hash 검증 통과한 데이터만 — stale resurrection 차단).
2. legacy episode-level: ``checkpoints/episodes/{eid}/planning_doc_analysis/manifest.json``
(구 PlanningDocAnalysisStep cascade 산물 — 옛 schema, raw read OK).
db: 호출자의 SQLAlchemy 세션. None이면 새 세션 생성.
r )load_project_checkpoint)dbN checkpointsepisodesplanning_doc_analysisz
manifest.jsonzutf-8)encodingz1Failed to load legacy planning doc checkpoint: %sdatar T)EpisodeF) SessionLocal
charactersz- **namez**
age_gender()role[]: description
visual_traitsu
외형:
locationsr r r r r key_relationshipsc 3 8 K | ] }d |d d|d yw)z- r6 r> relationshipNr) ).0rs r z'get_planning_context.. s, +
AEAb< !An$5#6 7s )*r *app.services.planning_doc_analysis_servicer- r r projects_direxistssortediterdirjsonloads read_text Exceptionloggerwarning
isinstancedictgetr
r app.models.projectr4 app.core.databaser5 queryfilterr* order_byepisode_numberallidr closeappendjoinr
r r r r r r )r* r+ r. ctxr- r3 base legacy_cpep_cpep_diraltrawexc availabler4 should_closer5 r0 r6 linescpartsrC locrelss r get_planning_contextrr > s=
C S2:"ED | && '
%) z!$;;oM <<> I
[[] 0 66 H::< #I 1
J **Y 0 0' 0 BCC (2#t'+? @A LL% ) #ii . b)I[I- CCK=+r#m2D1E-FGEww' |C,@+A BC LL% )
"YYu - )# HH_b 9i b1
i b1
I% "hh'8" = 88' ,D #y0!% +
AE+
"
J_ NNNPS TJ @ HHJ s+ .%O. A/P . P7PPP P1)N)r$ rO logging dataclassesr r pathlibr typingr app.core.configr getLoggerr! rS r r' rr r) r r ry sh ( $ 8 $ %
%
%
PvS vc v vr