Oj6) UdZddlmZddlmZmZddlmZmZm Z m Z m Z m Z ddl mZmZmZmZmZmZmZedGdd ZeZeZdd Zdd ZeZd ed <ddZ ddZddZddZddZ!ddZ"dd dZ#d!dZ$ddZ%ddZ&gdZ'y)"uStep Catalog — manifest + class + applicability 통합 단일 계약. Phase 1.1 (architecture-refactor-final/02-final-roadmap.md §Phase 1). 원칙 (01-principles-revised.md §5): - `STEP_MANIFEST` (step_manifest.py)는 **데이터 소스**. 수정은 여기서. - `STEP_CLASSES` (steps/__init__.py)는 runner 바인딩. - `STEP_CATALOG` (본 파일)는 **소비자 전용 View**. manifest + class + 파생 정보 병합. 소비자는 STEP_CATALOG만 본다. manifest/classes를 직접 참조하지 않음. 순환 import 주의 (Claude Phase 1 리뷰 M1): - 본 모듈은 `app.core.steps` 전체를 지연 import (`_build()` 내부). - `app.core.steps` 하위 개별 step 파일은 `app.core.step_catalog`를 import하면 안 됨. 필요 시 step 파일 내부 함수에서 지연 import로 회피. - 부팅 시점 `STEP_CATALOG = _build()`가 즉시 실행되어 `STEP_CLASSES`가 한 번 빌드되므로, ImportError/부수효과는 서버 기동 시점에 조기 노출됨 (late crash 방지). ) annotations) dataclassfield)AnyDictListOptionalSetType) STEP_MANIFESTcontainsget_all_downstream_recursiveget_depends_onget_downstream_stepsget_manifest_dictget_ordered_stepsT)frozenceZdZUdZded<ded<ded<ded<ded<ded <d ed <d ed <ded<ded<ded<dZd ed<dZded<dZd ed<ee Z d ed<dZ ded<dZ ded<dZ ded<y) StepEntryuStep의 모든 메타데이터와 runner 클래스 바인딩을 담은 단일 레코드. manifest에서 가져온 필드 + STEP_CLASSES에서 바인딩한 runner_cls + 파생 필드. strstep_idlabelcategoryfloatorder default_modelprovider List[str] depends_onboolfan_out applicability step_type lifecycleFresume_sensitiveNzOptional[List[str]]modifies_checkpointsinvalidate_downstream_on_edit)default_factoryconsumes_downstream Optional[str] replaced_byzOptional[List[Dict[str, Any]]] sub_stepszOptional[Type[Any]] runner_cls)__name__ __module__ __qualname____doc____annotations__r%r&r'rlistr)r+r,r-K/Users/manta/Documents/Projects/TheRoad-I1/backend/app/core/step_catalog.pyrr#sL JM LM MNN"d"04-4*/!4/&+4%@@!%K%04I-4&*J#*r5rc<ttjS)uL등록된 전체 step_id 목록 — STEP_CATALOG 구축 이전에도 안전.)r3r keysr4r5r6 get_step_idsr9Qs  ""$ %%r5Dict[str, StepEntry]c Nddlm}i}tjD]@\}}t did|d|dd|dd|dd|j ddd |j d dd t |j d gd t|j d d d |j d dd|dd|ddt|j dd d|j ddt|j dd dt |j dgd|j dd|j dd|j |||<Cddlm }ddl m }m }m }m}ddlm} m} |j%|t'|t'||| | ||S)u=STEP_MANIFEST + STEP_CLASSES 병합하여 StepCatalog 구축.r) STEP_CLASSESrrrrr-rrr!Fr"alwaysr#r$r%r&r'r)r+r,r-)grounding_activation_contract)GROUNDING_MODE_V2_CHUNKGROUNDING_MODES PLANNED_MODESbuys_v2_research)MATERIALIZABLE_OWNER_TYPESREFERENCE_SUPPORTED_OWNERS)accepted_modes planned_modes chunk_modereference_owners ledger_ownersbuys_legacy_researchr4)app.core.stepsr<r itemsrgetr3r app.corer?app.core.grounding_moder@rArBrC.app.modules.pipeline.grounding_entity_contractrDrEassert_activationset) r<catalogsidinfo_actr@rArBrCrDrEs r6_buildrXVs,$&G"((* T   w- *% w-  ((?C8  XXj#.  DHH\267 )U34 ((?H= ;' ;' "$((+=u"EF "&*@!A +/txx8WY^/_*` !%TXX.CR%H I /! "hh{+# $$'',%  +2?;;@ O 4-(*30- / Nr5 STEP_CATALOGc,tj|SN)rYrN)rs r6 get_entryr\s   G $$r5c^tj|}|rt|jSgSr[)rYrNr3rrentrys r6rrs*   W %E%*4  !22r5cztjDcgc]\}}||jvs|c}}Scc}}w)u!직접 의존 하위 step 목록.)rYrMrrrUes r6rrs4*002 N2FCg6MC2 NN Ns77ct}t|}|rC|jd}||vr+|j||j t||rCt |S)u-재귀적 downstream (BFS). 결과는 정렬.r)rSrpopaddextendsorted)rvisitedqueuecurrents r6rrsZG  )E ))A, ' ! KK LL-g6 7  '?r5cBttjdS)u'order 오름차순 StepEntry 리스트.c|jSr[)r)rbs r6z%get_ordered_entries..sqwwr5)key)rgrYvaluesr4r5r6get_ordered_entriesrps ,%%'-> ??r5cvtjDcgc]\}}|js|c}}Scc}}w)uDresume_sensitive=True인 step_id 목록 (Phase 1.3 steps.py 소비).)rYrMr%)rUrbs r6get_resume_sensitive_step_idsrrs1*002 I2FCa6H6HC2 II Is55Nc|tDcgc]$}|jdk(r||j|k(r|&c}Scc}w)ulifecycle=active이며 (옵션) 특정 category 일치. applicability는 여기서 해석하지 않음 — 그건 StepRunner 런타임에서 app.core.applicability.resolve_applicability가 처리. active)rpr$r)rrbs r6get_active_entriesrusH'( (a ;;( "(8AJJ(rs$#(77 $!+!+!+R /& -`&,X "- %3 O @ J  <  r5