OjG)vdZddlmZddlZddlZddlmZmZmZddl m Z Gdde Z Gdd Z ejZdd Zdd Zdd Zej&d ZddZGddZej&dddZddZd dZGdde Zej&ddd d!dZd"dZgdZy)#usGROUNDING-V2 §8.5 — **조사 호출**의 누계 상한. ★★`ImageCallBudget` 과 **같은 꼴의 다른 owner** 다 (Codex). counter 를 나눠 쓰면 서로의 상한을 갉아먹는다 — 참조 이미지를 많이 구운 주행이 그날의 조사 예산을 먹어 치우는 식이다. 그래서 **세는 통을 따로** 둔다. ★그렇지만 **정지 기구는 새로 안 만든다.** `install_stop_check` · `get_current_stop_check` · `bind_current_stop_check` 는 이미지 전용이 아니라 일반 기구라 그대로 가져다 쓴다. 두 벌로 만들면 한쪽만 고쳐진다. ★★세는 것은 **물리 전송**이다 — 논리 호출이 아니다. 키 슬롯 failover 는 `FailoverOpenAIClient._invoke` 안에서 도므로 논리 하나가 물리 둘이 될 수 있다. 「몇 번 나갔나」를 막으려면 **나가는 자리**에서 세야 한다. ) annotationsN)AnyDictOptional)get_current_stop_checkc$eZdZdZdfd ZxZS)ResearchCallBudgetExceededu.상한에 닿았다. ★**네트워크에 닿기 전에** 오른다. 호출부는 이것을 잡아 그 대상을 `time_capped` · `limit_kind=transmission_budget` 으로 남긴다 — 「조사할 필요가 없었다」가 아니라 「이 주행의 상한 때문에 못 샀다」다. ct||_t||_t||_t |d|jd|jd|jy)Nu'research_call_budget 초과 — 상한=u · 쓴 것=u · 거절한 자리=)intcapusedstrsourcesuper__init__)selfr r r __class__s S/Users/manta/Documents/Projects/TheRoad-I1/backend/app/core/research_call_budget.pyrz#ResearchCallBudgetExceeded.__init__!sZs8I &k  5dhhZ|DII;W $  0 1)r r r r rrreturnNone)__name__ __module__ __qualname____doc__r __classcell__)rs@rr r s11rr c,eZdZdZdZddZddZd dZy) ResearchCallBudgetuF조사용 **물리 전송** counter. 상한을 넘으면 거절한다.)_cap_used_denied_lockct|}|dkrtd|||_d|_d|_t j |_y)Nru$상한은 0 이상이어야 한다: )r ValueErrorrr r! threadingRLockr")rr cap_ints rrzResearchCallBudget.__init__/sHc( Q;CG9MN N   __& rc|j5|j|jk\r7|xjdz c_t |j|j||xjdz c_dddy#1swYyxYw)uE전송 **직전에** 한 자리를 잡는다. 없으면 거절한다.)r r rN)r"r rr!r )rrs rreservezResearchCallBudget.reserve8s\ ZZzzTYY& ! 0  6CC JJ!OJ ZZs A&A<<Bc|j5|j|j|j|j|jz dcdddS#1swYyxYw)N)r r denied remaining)r"rr r!rs rsnapshotzResearchCallBudget.snapshotAs< ZZ99djj"ll!%TZZ!79ZZs Us 68T **rc #Kttdddzt_ dtdttdddz t_y#tdttdddz t_wxYww)u이 블록 **안의** provider 전송만 조사 호출로 센다. ★★★왜 필요한가 (Codex ②). `reserve` 를 `FailoverOpenAIClient._invoke` 라는 **공용 경계**에 두면, 같은 스레드에서 나가는 **다른** OpenAI 호출(이미지· 요약 등)까지 조사 예산을 먹는다. 그러면 상한이 재는 것이 「조사 전송」이 아니라 「그 스레드의 모든 전송」이 된다. 그래서 조사 호출을 내는 자리에서만 **팔을 든다**. 밖에서는 no-op 이라 다른 호출부의 동작이 **한 글자도 안 바뀐다**. ★중첩을 세는 것은 재진입(retry 안의 retry) 때문이다. armedrr)N)r=r6r@maxr2rrresearch_calls_armedrBYs]67A.2FL? 1gfgq9A=> s1gfgq9A=> sA9A (A9 )A66A9c*ttdddkDS)Nr@rr<r2rris_armedrDms 67A & **rceZdZdZddZy)OutboundAttemptu한 **논리 시도**(journal 의 send 하나) 동안 이 스레드에서 팔을 든 채 나간 전송 수. ★Codex BLOCK (PR #82 재리뷰 2026-09-03): 중앙 경로의 send 하나는 저작→검색→받기→판정 **여러 전송**이라, 우리 문이 두 번째 전송 앞에서 세웠어도 첫 전송은 이미 나갔다. 「안 나갔다」는 이 계수가 **0** 일 때만 증명된다. 팔을 안 든 채 돈 시도는 셀 수 없으므로(`armed=False`) 증명이 없다 → uncertain. c0d|_t|_y)Nr)countrDr@r.s rrzOutboundAttempt.__init__ys Z rNrr)rrrrrr2rrrFrFqs  rrFc#K|xs t}ttdd}| g}|t_|j | ||j y#|j wxYww)uq이 블록의 전송을 `att.count` 에 센다 — 스레드 지역 stack 이라 worker 는 제 시도만 센다.attemptsN)rFr=r6rKappendpop)attstacks routbound_attemptrP~s\  ""C FJ -E } LL   sAA-AA-A**A-cbttddxsdD]}|xjdz c_y)NrKr2r))r=r6rH)rNs r_count_outboundrRs*vz406B6 Q 7rctsyt}||t}||j|t y)u5조사 전송 **직전**. ★`research_calls_armed()` 밖에서는 **아무 일도 안 한다**. ★★그래서 이미지·다른 스텝의 호출부가 영향을 안 받는다 — 같은 공용 경계를 지나가지만 팔을 안 들었으면 그냥 지나간다. ★정지 확인이 **예산보다 먼저**다 (Codex ①). 이미 마감된 주행은 예산도 슬롯도 안 먹고 **provider 를 0회** 부른다 — 예산이 안 깔린 조사 경로에서도 정지는 들려야 하므로, `budget is None` 보다 **앞에** 둔다. N)r)rDrr>r*rR)r stop_checkr7s rreserve_current_research_callrUsA :')J  !F f%rceZdZdZdZy)RunDeadlineExceededu주행 전체 벽시계가 지났다. ★`limit_kind=run_deadline` 로 남는다. ★표식(`is_run_deadline`)을 달고 다닌다 — 정지 표는 호출부가 아무 예외나 올릴 수 있어서, 타입 하나로 못 가른다. TN)rrrris_run_deadliner2rrrWrWs OrrW)deadline_secondsnowc# Kddl}ddlm}m}m}|xs |j  t }|}t|} t| |f  fd } ||  | | tn t|||y||yy#| tn t|||w||wwxYww)u한 **주행**의 조사 상한을 연다 — 전송 수 ②와 벽시계 ③. ★★③ 을 「새 대상을 안 시작한다」는 loop 조건으로만 두면 **팬아웃 안에서 이미 제출된 것들**이 계속 나간다. 정지 표로 깔면 `reserve` 자리에서 막힌다 — 그게 **네트워크 직전**이다 (GROUNDING-V2 §8.5). ★들어올 때 걸려 있던 예산·정지 표는 **되돌린다**. 안 그러면 이 주행이 끝난 뒤에도 남의 호출이 이 상한을 본다. rN)rinstall_stop_checkuninstall_stop_check)r cb||z tk\rtddy)Nu주행 마감 uO초가 지났다 — 남은 대상은 `time_capped`(run_deadline) 로 남는다)floatrW)_prevclockrYstarteds r_checkz"research_run_scope.._checksL w E*:$;;)$%5$67@@AArr8r:) r rYrZ_timerr\r] prev_budget prev_checkr7rcrarbs ` @@rresearch_run_scoperjsBB  "5??EgG$&K')J C (F6## A 6" /     ; '  '!$&":. (     ; '  '!$&":. (sA!C 'B+.C /CC cddl}ddlm}tt |||j |dfd }|S)u팬아웃으로 **예산과 정지 표를 같이** 실어 보낸다. ★`install_budget` 은 스레드 지역이라, 그냥 넘기면 worker 는 예산을 못 본다 — 그러면 상한이 그 자리에서 통째로 no-op 이 된다. rN)bind_current_stop_checkc2t} t r4t5|i|cddd| tSt|S|i|| tSt|S#1swY)xYw#| twt|wxYwr4)r>r8rBr:)argskwargsprevr@r7inners r_runz*bind_current_research_budget.._runs!#   6 " %)+ $1&1,+ | "t$$)&)| "t$,+ | "t$s' A<A0 A<A<0A95A<<B)rnrrorrr) functoolsrerlr>rDwraps)fnrsrlrrr@r7rqs @@@rbind_current_research_budgetrvsF B  !F JE #B 'E__R%%" Kr) rrDrBrjrWr rvr>r8rUr:)r7rrrrI)rzOptional[ResearchCallBudget])rboolr4)rNzOptional['OutboundAttempt']r0)r r rYzOptional[float]rZr)rurrr)r __future__r contextlibr%typingrrrrer RuntimeErrorr rlocalr6r8r:r>contextmanagerrBrDrFrPrRrUrWrjrv__all__r2rrrs #&&>11"99@  + ??&+       ., HL"&-/-/-/` F r