OjHdZddlmZddlZddlmZmZmZddlm Z m Z m Z ddl m Z ddlmZddlmZdd lmZej*eZd Zddd  dd Zej4Zej6Zdd ZdddddZddZGddee ZGddee Z Gddee Z!y)u!GROUNDING-V2 §2-3.5 — 분류·계획 스텝. 계획 §1.8 의 **★A 경계**다: 13.5 entity_merge short_id 중복 제거 (DB canon 아님) ↓ 13.6 ★grounding_plan 검색 0 · short_id 기준 · Sol classifier · route 확정 ↓ 13.7 entity_filter 보호 목록에 있으면 안 지운다 ← union 을 여기서 받는다 ★모드별로 하는 일이 다르다 (계약 §12): legacy **안 돈다** — manifest 의 `if_grounding_v2` 가 걸러 낸다 shadow_plan **안 돈다** — legacy 와 구별이 안 된다 v2 체크포인트를 만든다 — `entity_filter` 가 읽는다 ★``shadow_plan`` 을 파이프라인에 들여놓지 않는 이유: 이 스텝들은 production step id 를 쓰고 DAG 에 하류가 걸려 있어, `force` 로 한 번 돌리면 `_execute` 전에 그 하류가 통째로 무효화된다. shadow 관측은 **저장 CP 만 읽는 offline 재생기**(§2-3a)가 한다. ★``classify_samples`` 를 **실제로 부르는 자리**다. ) annotationsN)AnyDictList)GROUNDING_MODE_LEGACYGROUNDING_MODE_V2resolve_grounding_mode) StepRunner)grounding_carry)SUBJECT_ID_CONTRACT_VERSION)_EntityStepMixinexpected_judgesexpected_samplesc(|sdgSg}dD]C}|Dchc]}|xsij|}}|r d|vsd|vs0|j|dE|rtd|D}t|Dchc] }t|xsijd"c}}||k7r|jd|d ||D]g} |Dcgc]%}t|xsijd| k(r|'} }|s6t | |k7sE|j| d t | d |d i|D cic]P} | |Dchc]A}t|xsijd| k(rt|xsijd Cc}R} } }| j D cgc] } | D]} |  }} } t |dkDrIt t |t |kr)|jd|d tt |i}|D]?}|jt|xsijdgj|At|jD]\} }dD]}|Dchc]}|xsij|}}|rd|vsd|vr|j| d|dGt |dkDsV|j| d|dttt||Scc}wcc}wcc}wcc}wcc}} wcc} } wcc}w)u0표본들이 **같은 것을 잰 것인지** 본다. 어긋나면 사유 목록. ★기록만 하면 「같은 것을 N회 쟀다」가 성립하는지 아무도 안 본다. 측정 도구에만 있던 gate 를 여기로 올린다 (계획 §2-3.5 완료 조건). ★판정자가 여럿(패널)이면 **무너졌는지**까지 본다. production 은 ``strict_single_attempt=False`` 라 tier fallback 으로 gpt 슬롯이 gemini 로 넘어갈 수 있다. 그러면 실제 alias 는 둘 다 gemini 이고, 「판정자마다 한 값」만 보는 gate 는 **한 모델 패널을 통과시킨다**(Codex). 그래서 ①부탁한 집합 ②판정자별 표본 수 ③실제 물리 모델의 **다름**을 본다. 무너지면 fail-closed — 「미확정」이지 통과가 아니다. u!표본 지문이 하나도 없다)requested_judge_aliasjudge_model_aliasjudge_physical_modelNu 이 비었다c32K|]}t|ywNstr).0as T/Users/manta/Documents/Projects/TheRoad-I1/backend/app/core/steps/grounding_steps.py z#check_provenance..Gs6oc!foru3부탁한 판정자 집합이 다르다 — 기대 , 실제 u : 표본이 u개 — u개여야 한다ru0패널이 한 모델로 무너졌다 — 부탁 ) payload_hashprompt_versionr: u 이 표본마다 다르다 ) getappendsortedrlenvaluesset setdefaultitemsmap)runsrrbadcolrvalswantgotaliasgrpactualmsmflatby_judgegroups rcheck_provenancer=-s> 344C(,01Dqb c"D1tt|rTz JJ#n- . ( 6o664P4ac17--(?@A4PQ $; JJLTFR[\_[`a bE"Ld17--(?@AUJdCLCH0@$@ g\#c(8:;TQ gRu$@CQUAW@XY[ N1 JI2 QL S%97s6K/.%K4?*K9' L1AK>7LL *L>Lc@ddlm}ddlm}tj |}|s|d|dd||d}t |D]\}} |||||d }|d||<|S#t$r2} |d |d |d |dt| jd| d| d } ~ wwxYw)u팩의 **실효 바이트**를 지문에 넣을 수 있는 모양으로. 못 읽으면 그대로 표시. ★버전 문자열만 접으면 **같은 버전 디렉토리의 내용을 고쳤을 때** stale 을 못 잡는다. 실제로 이 저장소에서 「팩에 스템만 추가했는데 지문이 안 움직였다」를 두 번 냈다(`test_published_pack_ratchet` 참조). rAppError)resolve_effectivezgrounding.pack_stems_unknownu. 의 지문 대상 파일을 안 적어 뒀다icodemessage status_code)moduleversionN)kindrGdbzgrounding.pack_unreadable/(u-) 팩을 못 읽어 지문을 못 만든다: r$raw_content_hash) app.core.errorsr@app.modules.prompt_loaderrA _PACK_FILESr%r' Exceptiontype__name__) rFrGr@rAstemsoutstemrHeffexcs r_pack_fingerprintrXos); OOF #E /hLM  &,@CUm d #FDtW'+-C*+D $ J 0"81TF!D61^ I../r#8     s A"" B+-BB)systemprompt) a0_schemaschema)rY)classify_schemar])rY) claims_schemar])rY) chunk_schemar]) merge_systemr[) merge_schemar]) grounding_a0grounding_classifygrounding_claims_searchgrounding_chunkcddl}ddl}|j|j|ddj dj ddS)NrTF sort_keys ensure_asciizutf-8)hashlibjsonsha256dumpsencode hexdigest)payloadrl_jsons r _hash_payloadrtsF >> Gt% @GGP ik#2 c"eZdZdZdddZddZy)GroundingA0Stepu★**거르기 전에** 원문에서 고증 후보를 건진다. 검색을 하지 않는다. 뒤 단계의 추출 규칙들이(한 번만 나옴 · 착용물 · 고정 설비 · 텍스트만 다른 종이류) **고증 대상을 정확히 같이 걸러 낸다.** 그래서 그 앞에 선다. ★`legacy` 에서는 manifest 의 `if_grounding_v2` 가 not_applicable 로 걸러 **이 스텝 자체가 안 돈다.** c ddlm}t|j}|tk(r!t j dddd|gddddS|j}|jd}|xsijdxsi}|||j|jt|jd xsd jt|jd xsd j|j|j }|jd xsg}i} |D]:} | j| jddddz| | jdd<<t j dt|| t|jdxsgt|t|t|jdxsg|j!d|i|d| idS)Nr)collect_candidatesu5grounding_a0: mode=legacy — 아무것도 안 한다T)mode candidatesskipped search_calls)completed_countapplicable_count failed_countdatavisual_world_rulesrerarregion) project_id episode_idrrproject_config opik_metadatar{ owner_type?r!u7grounding_a0: 후보 %d개 %s · 지어낸 인용 %d건 hallucinatedrz owner_countsr~rr config_hashr)!app.modules.pipeline.grounding_a0ryr rrloggerinfo_load_cleaned_text_load_prev_checkpointr%rrrstripbuild_opik_metadatar( _config_hash) selfrzryg_modefulltextrules_cprulesrTcandsownerscs r_executezGroundingA0Step._executesH'(;(;< * * KKO P'(aQR%+2$-.01 1**,--.BCR$$V,2 4??EIIe$*+113uyy*0b1779..224   %+!#A/5zz!%% c:RTU/VYZ/ZF155s+ , MJCGGN,C,Ir(J L #5z #E  7 =2>,,.VCsCNFC   ruc ddlm}ddlm}t ||j |j ttd|jdS)u★팩 바이트·계약 버전을 지문에 접는다. 안 접으면 팩을 고쳐도 resume 이 **옛 체크포인트를 그대로 건너뛴다** — 고친 것이 아무 데도 안 닿는다. rcompute_config_hash)rcrc)base a0_contractsubject_contractpack) app.core.step_runnerrapp.modules.pipelinercrtrA0_CONTRACT_VERSIONr rXPROMPT_PACK_VERSION)rr_a0s rrzGroundingA0Step._config_hashsF =<'(;(;<22 ;%nc6M6MN    ruNresumerzrreturnDict[str, Any]rr)rR __module__ __qualname____doc__rrrurrwrws! F rurwc veZdZdZd d dZeddddddddddd d dZd d Zy)GroundingPlanStepu@고증 후보 분류·계획. ★**검색을 하지 않는다.**c^ ddlm}m}ddlm}ddlm}ddlm}t|j}|tk(r9tjd|j|gdd|jS|j!d }|xsij#d xsi} |j!d } | xsij#d xsi} t%| j#d xsd j'} t%| j#dxsd j'} | r| sddlm}|dd| d| dd|j!d}|xsij#d xsij#dxsg}t-j.| |j0|j2d |}|d}|d}|d}|d}|j#dxsi}tjdt5||||j#dd|j#d dz}|rtj7d!||j#d"xsd#Dcgc]}|j#d$d%k(r|d&}}||| j#d'xsg| j#d(xsg| j#d)xsgd*|+}|d,s&tj7d-|d.t9|d/t;|j#d0xsdt;|j#d.xsdz }|dkDrFtj7d1||j#d0|j#d.|j#d2|sXi}|D] }|j#|d3dd4z||d3<"|j|t=|d||||||j5 S||t>| | |j|jA6}|j#d7xsg}t=|j#d8xsg} tC|t=|t>9}!| t=|k7r |!jEd:t=|d;| |!r#ddlm}|djG|!zd?g}"|D]g}#|d@j#|#d&g}$||$}|"jEi||#d&|#dA|#dB|#j#dCxsij#dDdEi|"|z}%i}&|%D] }|&j#|d3dd4z|&|d3<"tIdF|%D}'tjdG|t5|"|&|'|j||%t5||&|'|j#dHd|j#d7xsg|||||jI Scc}w)JNr)DEFAULT_JUDGESclassify_samples)decide_route_from_samples)completeness_report) build_subjectu7grounding_plan: mode=legacy — 아무것도 안 한다T)decided subject_countr|r entity_mergerrrrrr?z$grounding_plan.missing_world_contextu4visual_world_rules 에 시대/지역이 없다 (era= , region=)rBrcr{rr source_step a0_candidatessubjectsunbound carry_reasonscarriedcandidate_ledgeru?grounding_plan: A0 후보 %d개 중 %d개를 물려받았다 %s ambiguousduplicate_surfaceu?grounding_plan: 표면형이 모호해 결속 안 한 것 %d건rowsr dispositionpromotedresearch_subject_id characters locationsprops) characterlocationprop) promoted_idscompleteu=grounding_plan: A0 후보 %d개가 산출에 안 남았다 %s missing_countmissingentity_missing_countugrounding_plan: 엔티티 행이 없어진 A0 후보 %d개를 **승격으로 살렸다** — 추출이 지운 것이다. 조사는 계속되지만 그 사실은 남는다 (entity_missing=%d · missing=%d · promoted=%d)promoted_countrouter!)rrcounts completeness a0_carriedrrr)samplesrrrrr.judgesru@분류기가 돌린 판정자가 계약과 다르다 — 계약 r z"grounding_plan.provenance_mismatchu)같은 것을 N회 잰 것이 아니다: z; i by_subject surface_formr provenanceshort_id)r _surface_form _owner_type _short_idc3DK|]}|jdsdyw)unstabler!Nr%)rds rrz-GroundingPlanStep._execute..s=%Q155+:[b%%f-388FL"%% T__&h@$ "o.  "!99%78>B UM7M ;!%%k15#''(;Q?@  NN\# % 033F;ArA<Am, :,-A <%X!l39r [17RLL)/R0 " # j! NNZ!/2F6);L4M O VZZ 67<1=&**_-234 A: NNM #9: ?+VZZ8H-I  K$&D#'88AgJ#:Q#>QwZ ::fd7m1%)+1g,9/?*.*;*;*= ? ? o3v..224 wwv$")/R0  0,. tN+ + JJ~./y D E  09CdiiPSnT  )+A|$((+@)A2FD)$/A NN'()>'?!">!2 eeL17R<F1W: =%== OCL&( <zz EX(''/15&BG':J))+  C.s%@(>1 '{{1a0(>srrr) rzrrrrr}r.rrrunresolved_carry_countrrTr|rr)rrUNBOUND_REASONSrr%r(r)rrrrrrr.r|rrrrrunresolved_carryrrdonerrrs @rrzGroundingPlanStep._wraps%  %2@(.(>(>@@ *//@EAF%& s7|+c3@!!%%(=">Aw3@/AA*l,*JB$$&6(.B!1 6B# " !%GI  & &!(GI # $$&  73@s %C <C cddlm}ddlm}ddlm}ddlm}t||j|tj|tttd|jD|j t#d|j$d S) u★팩·계약·**표본 수**·**판정자**·대상 모델을 접는다. 표본 수를 바꾸면 판정이 달라지는데 지문이 안 움직이면 옛 판을 그대로 쓴다. ★**판정자 목록**도 마찬가지다 — `gpt+gemini-pro` 를 `gpt+grok` 으로 바꿔도 지문이 안 움직이면 resume 이 **옛 판정을 그대로 건너뛴다**. 누가 답했는지가 바뀌었는데 다시 안 묻는 것이다 (Codex). rr)grounding_classifier)OVERLAY_CONTRACT_VERSIONPLANNER_CONTRACT_VERSIONc32K|]}t|ywrr)rjs rrz1GroundingPlanStep._config_hash..s@-?SV-?rrd) rplanner_contractcarry_contractoverlay_contractrrrclassifier_contractr)rrrrrrrrrtrrCARRY_CONTRACT_VERSIONr rr'rCLASSIFIER_CONTRACT_VERSIONrXr)rr_gcrrs rrzGroundingPlanStep._config_hashsz =DSS'(;(;< 8$;; 8 ;& @S-?-?@@#&#B#B&&:&)&=&=?#   rurr)rrrzList[Dict[str, Any]]rrrDict[str, int] | Nonerrrrr.zList[Any] | Noner|boolrDict[str, Any] | Nonerrrrrr"rr$rrr)rRrrrr staticmethodrrrrurrrsJm ^.2!#$t#4 !b598< = += DG=  = ,<= = 4I=  = 14 = 3 = !6 = "= = ~  rurceZdZdZdZdZdZdddZddZdZ dd dd Z d Z dd Z d Z ddZddZedddddddddddddd ddZy)GroundingResearchStepu★**출처 붙은 조사를 실제로 산다.** GROUNDING-V2 §2-4b. `grounding_plan` 이 `route="research"` 로 표시한 것만 조사한다 — `skip` 은 안 산다. 그게 계획의 뜻이다. ## 시간 통제 세 겹 안에서 돈다 (§8.5) `research_run_scope(cap=, deadline_seconds=)` 로 열고, 그 안에서 `search_claims` 가 호출마다 마감을 건다. 셋 중 어디에 걸리든 판정은 같다 — `time_capped` · `unresolved` · retryable. 무엇에 걸렸는지는 `limit_kind` 다. ## ★**main thread 만** 결과를 남긴다 `call_with_deadline` 은 **취소가 아니라 포기**라, 버려진 worker 가 나중에 값을 들고 온다. 그 값은 `search_claims` 가 이미 버렸고 여기서는 **돌아온 행만** 저장한다 — worker 는 바깥 호출과 감사 기록만 한다. ## batch 크기는 **1** 이다 §4b 실험이 네 크기를 다 돌고 「후보 없음 · 개별 호출 유지」로 끝났다. 어긋남은 어느 크기에서도 0이었지만 **크기를 키울수록 조사량이 말랐다** (계약 통과 claim 19 → 16 → 10 → 9). 그래서 기본값을 안 바꾼다. <g @r!cFddlm}ddlm}ddlm}t j}|tk(r)tjdj|gdSj\}}|s|r)tjdt|t|sEtjd t|j|g||j Sj! }t#|j%d xsi} t'|d } t)|d} t)|d} D cgc] } | d| vs | c} | s| r)tjdt| t| s>tjdj|g||| | | j St+jj%dxs j,}t/jj%dxs j0}tjdt||dfd}|||5}|j3||j4j7j8j:j=| }dddj%dxsg}j?}|Dcgc]}|j%ds|}}tjd|j%dd|t|j||||j%dd|j%dd||| | | j Scc} w#1swYxYwcc}w)!Nr) openai_client)research_run_scopereu;grounding_research: mode=legacy — 아무것도 안 한다T)rr|u@grounding_research: 인용 없는 대상 %d · 못 세운 것 %du;grounding_research: 살 대상이 없다 (인용 없음 %d))rrr no_sourcerrrrexpected_input_hashesadmittedcapped already_doneruCgrounding_research: 이미 끝난 것 %d · 상한에 밀린 것 %du,grounding_research: 새로 살 것이 없다) rrrr-rr2deferredexpectedrresearch_transmission_capresearch_run_deadline_secondsuFgrounding_research: 대상 %d개 · 전송 상한 %d · 마감 %.0f초c8j|gz y)u|★★**산 것을 한 호출마다 바로 남긴다.** 9개 중 7개째에 끊기면 앞의 7개를 통째로 잃고 다시 사야 한다 — 실제로 그 부류의 결함을 이 프로젝트에서 냈다. ★이 콜백은 `search_claims` 가 **main thread 에서** 부른다. 버려진 worker 는 여기 못 온다. r.N)_save_revisions)rowrrsavedrrs r_persistz0GroundingResearchStep._execute.._persist]s, T))3%s17*9 9Eru)capdeadline_seconds) max_retries)modelrr batch_sizerIron_batchbatches limit_kinduXgrounding_research: 논리 %d회 · 물리 %s · 상한에 걸린 것 %d · 저장 %d행r bought_calls) rrrbudgetrrDr-rr:r2r3r4r) app.core.openai_keysr*app.core.research_call_budgetr+rrer rrrr_wrap_research_research_targetsrr(r_plan_admissiondictr%r*rrDEFAULT_TRANSMISSION_CAPfloatDEFAULT_RUN_DEADLINE_SECONDS search_claims SDK_RETRIES _search_model BATCH_SIZErIrsnapshot)rrzr*r+gcsrr-r admissionr4keepr3alreadyr r<deadliner;rErTrspentr1r1rrr:rs` @@@@rrzGroundingResearchStep._execute"s6DG'(;(;< * * KKU V&&vB&E E484J4J4L1#vy'  NN]y>3w< 9 KKUI (&&RS#W --/'1 1((s6(J  &=>D"E9Z() (+,y01'Lx!1-B+Ct+KAxL h KK]G c(m 5 KKF G&&RS#W$x!t/@/@/B 'D D $%%))*EF3224,,001PQ> ==? \M3 2  9 9 C( Cv###//:H((*F??tww"668! $#CDwwy!'R!!9TQUU<%8!T9 &GGOQ/F U L"" 3v(C3 84+<+<+> #@ @aMFD C:s% N N $AN1NNNc <ddlm}m}|Dcgc]}|d }}|||Dcic]}|d||c}|j|||j t |j jdxsdxsd|jScc}wcc}w)uY무엇을 새로 살지. ★**바깥 호출 전에** 정한다. ★이미 끝난 행(`completed`)은 다시 안 산다. 상한을 넘은 것은 버리지 않고 `capped` 로 남아 다음 주행이 **앞에서부터 이어간다** — 상한만 두고 이어가는 계약이 없으면 영구 partial 이 된다. r)plan_admissionsubject_payload_hashrr.research_subject_capN)subject_payload_hashesresearch_inputs done_rowsr<r@) %app.modules.pipeline.grounding_claimsr[r\_research_inputs _done_rowsrrr%rR)rrrrr[r\r idss rrJz%GroundingResearchStep._plan_admission~s 22::Aq&': EM$OEM%&&;$<$8$;%]]dgg].F%D  ruN)provc ddlm}ddlm}t |xsi}|s|j nd}|||r|j dn|d|r|j dn|d|jd |r|j d n|d|jd t|td |i|j d xsd |j dxs|j|j dxs|jd S)u!입력 신원 중 **대상과 무관한** 좌표. ★한 곳에서 만든다. ★★`prov` 를 주면 그 호출이 **실제로 쓴** 좌표를 쓴다. 입력 신원은 「무엇을 요청했나」이고 provenance 는 「무엇이 답했나」라, 계약이 그 일곱 쌍의 **일치**를 검사한다 — 저장할 때 살 때의 값을 그대로 쓰면 팩이 바뀐 판에서 둘이 갈린다. ★프로덕션에서는 같은 주행이 같은 팩으로 사고 저장하므로 값이 같다. rr,rNprompt_pack_versionrGprompt_raw_hashrSrLschema_raw_hashplannerprovideropenair?) rrclaims_pack_versionrnropolicy_versionpolicy_contract_hashrqr? model_version) rrerrrKrjr% SYSTEM_STEM SCHEMA_STEMrrtrQ)rrrrkrTrpvrs rrbz&GroundingResearchStep._research_inputss H &$*" #%tzz|4&')%'FF+@$A/3I=?'8 9 $W coo >$6!8=?'8 9 $W coo >$6!8!":;$145%7z*6hVVG_<(:(:(<VVG_D0B0B0D  rucfddlm}|jgS|jj|j |j |j k(|j |j k(j}|Dcgc]&}|j|j|jd(c}Scc}w)uS이 에피소드의 **저장된 조사**. ★없으면 전부 새로 사게 된다.rGroundingResearchRevision)rresearch_input_hashstatus) app.models.projectr|rIqueryfilterrrallrr}r~)rr|rr1s rrcz GroundingResearchStep._done_rowss@ 77?I 781<<O1<<OQ /34.2)*(=(=()(=(=88%.24 44s+B.cddl}ddlm}m}ddlm}ddlm} m} |D cic]} | d|  } } |j|jj} d}|D]}t|jdxsi}|s&tjd|jd J|jd xsijd xsg}|jd xsgD]A}| j|}|s|Dcgc]6}t|tst!|jdxsd |k(r|8}}|r|djd xsgng}|r|djdxsgng}| |}|j#|||}| |j$|j&|||||i||d|ddt!|j)t+|jd|  }|j,!|j,j/|di||dz }D|j,|r|j,j1|Scc} wcc}w)u산 것을 **정본 테이블**에 남긴다. ★판정은 `build_revision_row` 가 한다. ★호출부가 `decide_delta` 를 따로 부르고 결과만 넘기면 저장된 판정과 저장된 claims 가 갈릴 수 있다 — 그래서 한 곳에서 한다. ★같은 시도를 두 번 안 넣는다(유일 제약). 재개하면 `attempt_id` 가 달라져 새 행이 되고, 앞 행은 그대로 남는다. rN)datetimetimezoner{)build_revision_rowr\rruKgrounding_research: provenance 가 없는 행 — 저장하지 않는다 %s requestedparsedresultsrclaimsgaps)rrrkrtrv)rtrvrC) rrrr\r_rrr attempt_id time_capped created_atr!r)uuidrrrr|rarr\nowutc isoformatrKr%rr isinstancerrbrruuid4r#rIaddflush)rrrrrrrrr|rr\r by_idrnr9rkrsidsubjr1minerrsphrirs rr8z%GroundingResearchStep._save_revisionssX /@ 66>?h()1,h?ll8<<(224 C -34D ;$q'++h/52B6:Q F+1r+40**s604+6*#4??(+),$&vD F$ F245E2F13O1D F #4::<0!%SWW\%: ;"%$&77&GGKK 9 BE BCQM3b 77 1 GGMMOm@"Ls I>I%Ic|jdxsijdxsi}|jdxsgDchc]'}|jddk(r|jd)}}|jdxsijdxsi}t|jdxsd j}t|jd xsd j}|r|sd d lm}|d d|d|dd|sg||ggfS|jdxsijdxsi}|jdxsijdxsijdxsg} t j||j|jd| } | dD cgc] } | d|vr|  } } | D cgc]0} t| jdxsd jr| 2} } | D cgc]3} t| jdxsd js| d5}} t|| D chc]} | d c} z }| ||||fScc}wcc} wcc} wcc} wcc} w)u,계획이 `research` 로 표시한 대상 + 그 **원문 인용**. ★subject 는 `grounding_plan` 과 **같은 함수**로 다시 세운다 (`_carry.build_subjects`). 여기서 새로 발급하면 같은 대상에 다른 id 가 붙어 계획과 조사가 갈린다. grounding_planrrrresearchrrrrrrr?z(grounding_research.missing_world_contextu시대/지역이 없다 (era=rrrrBrrcr{rr source_quote) rr%rrrMr@rrrrr')rplanrr3rrrr@ra0rr pickedquotedr-rs rrIz'GroundingResearchStep._research_targetss**+;<B#f+$!# 7;xx 7J7Pb7P17P55>Z/+,7P1++,@AGR3v;%"$ %))E"(b)//1UYYx(.B/557& 0?7wizQRS! !sFB* *..~>D"c&k(%' )).9?RDDVLSS&-*, %% T__&b:#:.7.,-5.7$?V~.4"5;;=V?7=Fv!n 5 ;<BBD,-v F6 J6a#8!96 JJKsFIw66S167?F!Ks,I+I!5I&<8I+ I0 crddlm}t|jj dxs |j S)Nr)settingsgrounding_search_model)app.core.configrrrr% openai_model)rrs rrQz#GroundingResearchStep._search_modelLs4,4&&**+CD,++- -ruczddl}ddlm}ddlm}|j }t ||j|d|d|dt|djDcic]\}}||jd d c}}d |j|jd d |jdScc}}w)u★팩 바이트·계약 버전에 더해 **요청 계약**까지 접는다. 안 접으면 `strict` 나 `include` 를 고쳐도 resume 이 **옛 체크포인트를 그대로 건너뛴다** — 고친 것이 아무 데도 안 닿는다. rNrr,rFrGpack_manifest_hashrSrLr)rFrGmanifestrSTFrh)rrrequestr@)rmrrrrerjrtrr'r,r%rorequest_contractrR)rrsrrTrkvs rrz"GroundingResearchStep._config_hashRs <Gzz|'(;(;<x.T)_ !56'-T']-@-@-B&CE&CdaQUU#5r::&CE {{3#7#7#9T05#7//   Es"B7rrF) rrrErrDr|r-rr:r2r3r4rc|xsgDcgc]}|jds|}}|xsgDcgc]&}|jdr|jds|(}}t|xsd}t| xsd}t|xsgt|z t|z t|xsgt|zt|zt|t|zt|zt|ztt| xsdz|id|d|d|d|dtjd |xsgd |xsid |d |d t |Dchc]}t |jdc}dt|d|d|d| dt| xsddt| xsddt| xsidScc}wcc}wcc}w)u9★체크포인트 모양을 다른 스텝과 같게. 하류가 읽는 자리는 `data` 다. ★**상한에 걸린 것을 실패로 센다.** 세지 않으면 「시간이 없어 못 산 것」이 `completed` 로 지나가고, 하류가 그걸 「조사할 게 없었다」로 읽는다. rCerrorrrzr|rrr@rrErrD limit_kinds capped_countr-unbuiltsaved_revisionsr2r3r/r)r%rr(r'rRr'rrK)rrrrrErrDr|r-rr:r2r3r4rr1r1errorednsr8s rrHz$GroundingResearchStep._wrap_researchns6#jbjAjQUU<-@!jA#zrzBzeeGnQUU<-@zB )/r " '-R "4:2V>   &,B     v06'8061(+155+>'?06'8 9F R2"5"\%7R 8#$DR0%((hn")=)  BB,'8sF9F9+F> !Grr)rrrr)rrrrrrr)rrrrrrrrrDrr|r#r:rrrrr)rRrrrrLrNrRrrJrjrbrcr8rIrQrr%rHrrurr'r's4 "$* JZ@x(( ?C B 4DN27h-  88:""+,e!%t!$(4$*, / 36/ %(/ 7;/ =@/ %( / 2@ / / rur')r.z List[Any]rrrz List[str])rFrrGrrzDict[str, str])rrrrr)"r __future__rloggingtypingrrrapp.core.grounding_moderrr rr rr rrr app.core.steps.entity_stepsr getLoggerrRrrr=build_carry_indexmatch_candidaterXrOrtrwrr'rrurrs.#"",:N8   8 $ :>-.9'*93<9|,,(( PDO =4  ; & ; |R (*R h^ ,j^ ru