+ iHj!O  a0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI H t ^RI Ht^RIHtHtHtHt^RIHtHt^RIHt^RIHt^R IHt^R IHt]P>!] 4t!]PD!R RR 7t#R ]$R&Rt%RRlt&RR~RR/RRllt'RRlt(RRlt)RRlt*RRlt+RRRllt,R RR!R"/R#R$llt-].!0Rm4t/Rt0].!R*]044R+R,0,t1]/R-R.0,t2R%R/R&R0R)R1/t3R%R2R&R0/t4R'R(0t5R%R3R)R4/t6R5R6lt7R7R8lt8R9R:lt9R;R<lt:R=R>lt;R?R@ltRERFlt?RRGRHllt@RIRJltARKtBRLtCRMRNltDRORPltERQRRltFRSRTltGRURVltHRWRXltIRYRZltJRR[R\lltKR]R^ltLR_R`ltMRaR"/RbRclltNRdReltORRfRglltP].!0Rm4tQRhRiltRRjRkltSRlRmltTRnRoltU!RpRq4tVRrRRsRRtRRuRRvRRwR/RxRylltWRzR{ltXRR|R}lltY.ROtZR#)uCodex API runtime — App Server and Responses-API streaming paths. Every entry point takes the parent AIAgent first: ``run_codex_app_server_turn`` drives one ``codex app-server`` subprocess turn; ``run_codex_stream`` runs one streaming Codex Responses call.) annotationsN)suppress)SimpleNamespace)AnyCallableDictList)claim_stream_writerstream_writer_is_current)HERMES_TOOLS_MCP_SERVER_NAME)bypass_sdk_request_transform)buffer_connect_exhausted_notice)set_usage_anchorcodex_watchdog_statedefaultz"contextvars.ContextVar[Any | None]_codex_watchdog_state_varg@cV^8dQhRR/#)returnfloat)formats"8/home/ubuntu/.hermes/hermes-agent/agent/codex_runtime.py __annotate__r s))u)cT^RIHpV!4PR4p\V\4'dVPR4MRp\V\ \ 34'd,\V\4'g\R\ V44#\# \d \#i;i)u``agent.stream_drain_timeout`` (seconds) — how long the post-terminal SSE drain may block. The drain is a courtesy to Relay's finalizer, never a correctness requirement: ``final`` is fully assembled before it starts. A relay that never closes the socket after ``response.completed`` would otherwise wedge the turn until the idle watchdog discards the already-billed response (#103864). ``0`` skips the drain entirely. )load_config_readonlyagentstream_drain_timeoutNg) hermes_cli.configrget isinstancedictintrboolmax Exception_DEFAULT_STREAM_DRAIN_TIMEOUT)r agent_cfgvalues r_stream_drain_timeoutr+ s :(*..w7 9CIt9T9T 45Z^ ec5\ * *:eT3J3JsE%L) ) )(   (( sB B B'&B'argskwargsc ,V^8dQhRRRRRRRRR R /#) rfnCallable | Nonefail_msgstr fail_argsrr,tupler- dict | Noner)rs"rrr3s0::o::#:U:al:rcVfR#T!T/T;'g/BR# \d\P!T.TO5RR/R#i;i)zVInvoke an optional display/debug callback; a buggy hook must never tear down the turn.Nexc_infoT)r'loggerdebug)r/r1r,r-r3s&&$$*r _call_guardedr:3sG z: D#V\\r# : X9 9D9:s %AAc V^8dQhRRRR/#)rerror BaseExceptionrztuple[int | None, str]r)rs"rrr=s>>->rc Rp.pTp\4pVEeF\V4V9Ed5\V4^8Ed$VP\V44VP \ V4P 4VfRp\\4;_uu_4\\VRR4RR4pRRR4\V\4'd\VPR44pM,\V\\\34'd \V4pVP RJ;'dVP"'*pV'd VP$M VP pEKJVRP'V43# +'giL;i)z(serialized request bytes, exception class chain); the buffered ``httpx.Request`` content on OpenAI connection errors gives the exact byte count without logging payloads or URLs.Nrequestcontentutf-8z <- )setidlenaddappendtype__name__rr'getattrr"r2encodebytes bytearray memoryview __cause____suppress_context__ __context__join)r<request_body_bytesexception_classescurrentseenr@implicit_chains& r_codex_request_failure_detailsrW=s%&*#%$)GUD  "W+T"9c$i!m G  g!7!78  %G)$$!''9d"CYPTU%'3''%()@%A"GeY %CDD%(\" **d2WW7;W;W7W)7'%%W=N=N v{{+<= ==%$s E.. E> c(V^8dQhRRRRRRRR/#)r api_kwargsr#attemptr$attemptsrr)rs"rrrTs)"1"1"1s"1c"1VZ"1rc ^RIHp^RIHpVP R4p\ V\ 4'gV#\\P!V\R7PR44pWcP8:dV#.^rVFp \ V \4'd(V P R4R8XdV P R4MR p \ V \4'dOT!T R \V P R 4;'gR 4W3PR 7p W8wd/V CRV /CV^,rVPV 4K V'g)\ P#RWW`P R44V#\\P!V\R7PR44p \ P#RWWV VP R44/VCRV/C#)a#95429 criterion 3: a reconnect after an attempt that produced no stream event must not resend a pathological payload unchanged. Inline ``function_call_output`` strings over the per-result threshold (results that escaped commit-time persistence) are spilled through the standard policy -- bounded preview + recoverable ```` reference -- and ONE log line records the size delta. When nothing is prunable the resend is logged as unchanged. The caller's kwargs are never mutated; only the retried wire payload changes.)DEFAULT_BUDGET)maybe_persist_tool_resultinputrrArGfunction_call_outputoutputNcodex_zero_event_retrycall_idcall)r@ tool_name tool_use_idconfig thresholdzCodex zero-event retry (attempt %s/%s): no prunable tool output; resending payload unchanged (serialized_input_bytes=%s, model=%s)modelzCodex zero-event retry (attempt %s/%s): spilled %d oversized tool output(s) before reconnect, serialized_input_bytes=%s -> %s (model=%s))tools.budget_configr]tools.tool_result_storager^r!r"listrDjsondumpsr2rJ turn_budgetr#default_result_sizerFr8warning) rYrZr[r]r^itemsbefore pruned_itemspruneditemrareplacedafters &&& r_prune_zero_event_retry_payloadryTs3C NN7 #E eT " " E3/66w? @F +++q&'1$'='=$((6BRVlBl(#rv fc " "0Kc=@)ATA^A^X^=_8FRtRtvH!;$;(;VaZfD! IJQ]cesest{e| ~  <5<>'*, 1j 0'< 00rc V^8dQhRRRR/#)rr*rrr$r)rs"rrrys   S  S  rc\V\4'd^#\V\4'd \V^4#\V\4'd\\V4^4#\V\ 4'd8\ \4;_uu_4\\V4^4uuRRR4#^# +'gi^#;iN)r"r%r$r&rr2r ValueError)r*s&r_coerce_usage_intrys%%5!}%3u:q!!% j ! !s5z1%" ! " ! s B55 C c(V^8dQhRRRRRRRR/#) rr1r2 fail_extrarcountszCallable[[], dict]rNoner)rs"rrrs0 C C C3 CHZ C_c CrcVP'dVP'gR#VP'gVP4^RIHpVPP !VP3RV!V4/V!4BR# \d0p\P!YP.TOTN5!Rp?R#Rp?ii;i)zEnqueue per-call accounting for the SessionDB background writer. ``counts`` is built lazily inside the guarded try so a stub agent without a session DB is never touched.N)_agent_session_sourcesource) _session_db session_id_session_db_created_ensure_db_sessionagent.turn_usagerqueue_token_countsr'r8r9)rr1rrrexcs&&$* r_queue_token_countsrs    %"2"2"2C(((  $ $ &: ,,U-=-=oF[\aFboflfno C X//B*BcBBCsBA B C$B;;CcV^8dQhRR/#)rrdict[str, Any]r)rs"rrrsCNCN.CNrc aaaaaS;P^, un\VRR4p\SRR4pV3Rlo\V\4'd V'gmVe%\VRR4'dVP /4Ve-\ \VRR44'dVP 4\SRV3R lR 7/#^R IH pH p\VPR 44pV!\^\VPR 44V, 4\VPR44V^\VPR44VR7pVPp \VPR44;'g VPp R$U u/uFq\W4bK up oRV RVP RV /SCp VeCVP V 4\VRR4p \V \"4'dV ^8dWn\V\,4'd)^RIHpHpV!WP V4pVe V!SV4V P54F*wpp\7SRV 2\SRV 24V,4K, V!SP8VSP:SP<\SRR4R7oSP>e\ASP>4MRpVeS;PBV, un!SPDSPFuSn$Sn%RVRSPDR SPF/o\SR!V VVVV3R"lR 7/V CR#V /CSC#uup i \&d\(P+RRR7EL}i;i)%aTranslate Codex app-server token usage into Hermes accounting. Prompt bucket = uncached + cached input (the protocol exposes no cache-write tokens); a turn with no usage still counts as one API call. ``messages`` (the transcript mirror) lets real usage anchor the next preflight: this runtime bypasses the main loop's capture, and the mirror is never compacted natively, so without an anchor the rough estimate grows monotonically and hermes-mode fires thread compaction on tiny threads (#100381).token_usage_lastNcontext_compressorc f<\RRSPRSPRSPR^/VB#)ribilling_providerbilling_base_urlapi_call_countr)r#riproviderbase_url)extrars,rbilling/_record_codex_app_server_usage..billingsOD%++DDY^YgYgDxyD~CD Dr%awaiting_real_usage_after_compressionFnote_usage_less_responsez=Codex app-server api-call persistence failed (session=%s): %sc<S!RR7#)subscription_included) billing_moder)rsr0_record_codex_app_server_usage..s 7@W+Xr)r)CanonicalUsageestimate_usage_costcachedInputTokens inputTokens outputTokensreasoningOutputTokens) input_tokens output_tokenscache_read_tokenscache_write_tokensreasoning_tokens raw_usage totalTokens prompt_tokenscompletion_tokens total_tokensmodel_context_windowz$codex app-server usage update failedTr7)capture_usage_anchorrsession_api_key)rrrestimated_cost_usd cost_status cost_sourcezECodex app-server token persistence failed (session=%s, tokens=%d): %scL<S!R/SBSBRSPR8XdR/B#R/B#)rincludedrNr)status)r cost_fields cost_result token_countssrrrs<wsssGRGYGY]gGg,Csmqsrlast_prompt_tokens)rrrrr)&session_api_callsrIr"r#update_from_responsecallablerragent.usage_pricingrrrr!r&rrrr$context_lengthr'r8r9rlagent.usage_anchorrrrrsetattrrirr amount_usdrsession_estimated_cost_usdrrsession_cost_statussession_cost_source)rturnmessagesusage compressorrrrcanonical_usagerrf usage_dictcontext_windowrranchorkeyr*cost_usdrrrrsf&& @@@@r_record_codex_app_server_usagersH  q  D,d 3E 4d;JD eT " "%  !gj:ach&i&i  + +B /  !hwzC]_c/d&e&e  / / 1E#b#X Z G*%))4G*HI$-eii .FGJ[[\' .(AB+*5995L+MNZ_ O $11M$UYY}%=>^^/B^B^Ltvt89w22tvL!=2EGdGd ,@2>@J P  + +J 7$T+A4HN.#..>A3E,:)(D!!M%m5R5RT\]   UF + &&( U#'(3%8H)IE)QR)% _u~~`ghmoxz|`}K1<0F0F0Ru[++,X\H ((H4(;F;M;M{OaOa8Eu8'=+BTBTVcepewewxK VXds Nj M. M MMCv P LL?$L O PsMAM"M?>M? approx_tokensforceFc$V^8dQhRRRRRR/#)rrz int | Nonerr%rr)rs"rrrs#''z'ae'rv'rc*V'g\VRR4'gR#\VRR4;'gR\VRR4;'gRrT\PR\VRR4;'gR WEV4V'g8\\4;_uu_4^R IHpVPV4RRR4\VR R4pVe\VR ^4^,VnT;'g^Vn \\V4R R4p\V4'd V!VRR7M\VR4'dRVn \VRR4'gR^uVnVnRVn\#VR4RVn\'\VRR4;'gRRRR\VRR4;'gRR\VRR4;'gRRRRRR Ve\VR ^4M^RRRVRV/3R7V'g^RIHp V !V4R# +'giEL[;i)uRecord a Codex-native compaction boundary: the app-server owns the compacted thread, so local transcript rows are NOT rewritten — only session event/usage counters. compactedF thread_idNrturn_idzKcodex app-server compaction observed: session=%s thread=%s turn=%s force=%srnone)COMPACTION_STATUSrcompression_countrecord_completed_compaction) used_fallback$_verify_compaction_cleared_thresholdTrevent_callbackz.event_callback error on codex session:compresszsession:compressplatformold_session_idin_placeruntimecodex_app_serverr,)publish_provider_native)rIr8inforr'agent.conversation_compressionr _emit_statusrlast_compression_rough_tokensrGrhasattrrrlast_completion_tokensrr_last_compaction_in_placer:agent.compaction_eventsr) rrrrrrrrrecord_boundaryrs &&$$ r#_record_codex_app_server_compactionrs {E:: {D9??RyZ^A_AeAecew KK]|T2<BJ ;t/66OQST LJ ):+L?CJ <UD!&+E#'%!148@@DBr* '%T"B"H"Hb,X_`egsuyXzYAYAA&J)ZdZp7:?RTU+Vvw!3[)YX_ - C& =! s H H commandExecution fileChange mcpToolCalldynamicToolCall webSearchc#*"TF wrVxK R#5iNr).0m_s& r rs)R8Q!8Qsz!item/commandExecution/outputDeltazitem/fileChange/outputDelta agentMessage reasoning exec_command apply_patch web_searchexeccommandqueryc V^8dQhRRRR/#)rparamsr#rr2r)rs"rrr#s1111rcVPR4;'gVPR4p\V\4'dV#R#)zDNon-empty text carried by an app-server delta notification, else "".deltatextr)r!r"r2)rrs& r _delta_textr#s8 ::g  4 4&**V"4DdC((40b0rc V^8dQhRRRR/#)rrvr#rz list[dict]r)rs"rrr)sKKKKrcVPR4;'g.Uu.uFp\V\4'gKVNK up#uupi)changes)r!r"r#)rvcs& r _item_changesr)s;+11r1 J1!jD6IAA1 JJ Js AAc V^8dQhRRRR/#)rrvr#rr2r)rs"rrr-sGG4GCGrcpVPR4;'gRpVR8XdKVPR4;'gRVPR4;'gRr2V\8XdV#RV R V 2#VR 8XdVPR4;'gR #\PV4;'g T;'gR#) zJSynthetic Hermes tool name for a codex item (mirrors CodexEventProjector).rGrrservermcptoolunknownzmcp..rdynamic)r!r _STATIC_TOOL_NAMES)rv item_typerrs& r_codex_item_to_tool_namer#-s &&BIM!xx)22UDHHV4D4Q4Q !==tYT&QRSWRXCYY%%xx,,9,  ! !) , F F F FYFrc V^8dQhRRRR/#)rrvr#rr)rs"rrr8s R Rd Rt Rrc vVPR4;'gRpVR8Xd9RVPR4;'gRRVPR4;'gR/#VR8XdmR\V4Uu.uFTpRVPR4;'g/PR4;'gR R VPR 4;'gR/NKV up/#V\9d8VPR 4;'g/p\V\4'dV#R V/#VR 8XdR VPR 4;'gR/#/#uupi)zSArgs dict for tool_progress_callback("tool.started"); mirrors the projector shapes.rGrrr cwdrrkindupdatepath argumentsrr )r!r_MCP_LIKE_ITEM_TYPESr"r#)rvr"rr,s& r_codex_item_to_argsr,8s2 &&BI&&488I.44"eTXXe_=R=RPRSSL %24%8:%8$aeeFm&9&9r%>%>v%F%R%R(TZ\]\a\abh\i\o\omop%8:; ;((xx $**!$--tFK3FF1:k1IGTXXg&,," -QrQ :s0D6D6'D6D6c V^8dQhRRRR/#)rrvr#rrr)rs"rrrFs   # rc@VPR4;'gRpV\9d8VP\V,4;'gRR,;'gR#VR8Xd\V4Uu.uF,q"PR4'gKVPR4NK. ppV'dLRPVR,4\ V4^8dR \ V4^, R 2,#R,#R#V\ 9dVPR 4;'g/p\ V\4'dOV'dG\\\4;_uu_4\P!VR R 7R,uuRRR4#R#uupi +'giR#;i)zXShort preview for the tool.started bubble; None when nothing useful (UI tolerates None).rGr:NxNNrr), :NNz, +z morer*F ensure_ascii) r!_PREVIEW_FIELDSrrQrDr+r"r#r TypeErrorr~rmrn)rvr"rpathsr,s& r_codex_item_to_previewr7Fs/ &&BIO#34::DAIITIL (5d(;M(;1uuV}v(;Mch %)$s5zTU~#c%j1n-=U(C^r[]^rnrr((xx $** dD ! !d)Z00zz$U;DA10 N 10 s2FFF  F c V^8dQhRRRR/#)rrvr#rztuple[str, bool]r)rs"rrrVs2BrcVPR4;'gRpVR8Xd\VPR4;'gRVPR4r2\VRJ;'dV^8g4pV'd RV RV 2V3#TV3#VR 8XdNVPR 4;'gR p\VPR 4;'g.4pR V RV R2VR93#VR8XdxVPR4;p'd%R\P!VRR7R, 2R3#VPR4pVe"\P!VRR7R,R3#RR3#VR8XdVPR4;'g.VPRR4r\ V \ 4;'dT p V 'd \P!V RR7R,MRV 2\V 4'*3#R#)u(result_text, is_error) for a completed tool item — display-facing text for live tool cards (the persisted history keeps the projector's ``{exit_code, output}`` envelope instead).rGrraggregatedOutputexitCodeNz[exit z] rrrrzapply_patch status=r0z change(s)successrr<z[error] Fr2:NiNTresult:NiNr contentItemszsuccess=>appliedr< completed)rF)r!r%rDrmrnr"rl) rvr"out exit_codeis_errorrnr<r= content_itemsr< has_itemss & r_codex_item_completion_payloadrGVs &&BI&&"45;;TXXj=QY -@@)q.A08& 3se,HLLcHLLL (#00y #))r *$VHBqcoooM!HHW% %5 %djjUCEJKLdR R(#AGAS 66u=^cccY[^ccc%%!%.!9!?!?R)UYAZw}d3EE HQ =u=eDYabiajWkrvw~rn rc$V^8dQhRRRRRR/#)rrvr#namer2rr)rs"rrrns&ll$lclclrcf^RIHpVPR4;'gRpVPR4;'gRpRRVPR4;'gR R V 2R R V 2/PV4pT!T;'g\PW14VPR 4;'gR4#)zkDeterministic tool_call id mirroring CodexEventProjector (live TUI card correlates with projected history).)_deterministic_call_idrGrrrrmcp__rr__rdyn_rC)&agent.transports.codex_event_projectorrKr!_STABLE_ID_PREFIXES)rvrIrKr"rprefixs&& r_stable_call_idrRnsM &&BI 88F  ( (yDuTXXh%7%@%@5$AD6JL]aefjek_l m q qr{ |F !&"T"T,?,C,CI,TVZV^V^_cVdVjVjhj kkrcV^8dQhRR/#)rrzCallable[[dict], None]r)rs"rrrws``1G`rc @aaaaaa a a /o RRRR/RV3Rlllo RV V 3RlloRV V 3R lloR V 3R llpR VV 3R lloRVVV3Rllo\UUu/uFwr#V\P!WR7bK uppo V3RlS R&V3RlS R&RV V 3RllpV#uuppi)a?Build the ``on_event`` callback for ``CodexAppServerSession(on_event=...)``. Tool items fire ``tool_progress_callback`` plus the stable-ID ``tool_start_callback`` / ``tool_complete_callback`` card hooks; deltas go to ``_fire_stream_delta`` / ``_fire_reasoning_delta``; a completed agentMessage goes to ``_emit_interim_assistant_message`` (the gateway's ``already_streamed`` check dedupes against streamed deltas). Current-turn progress refreshes the activity clock even without display hooks. Every callback is guarded so a buggy display hook cannot tear down the turn loop.r,r-Nc 0V^8dQhRRRRRRRRRR R R /#) rattrr2r1r3rr,r4r-r5rrr)rs"rr8make_codex_app_server_event_bridge..__annotate__s@bbsbcbsb%bVabmqbrcB<\\SVR4V.VO5RVRV/R#)Nr,r-)r:rI)rVr1r,r-r3rs&&$$*ragent_cb4make_codex_app_server_event_bridge..agent_cbs&geT40(aYaTaZ`arc V^8dQhRRRR/#rrvr#rrr)rs"rrrWs A A A$ Arc  <VPR4;'gR\V4r!\V4pV'dW#\P!43SV&S!RRVRV\ V4V3R7S!RRV\ W4W#3R7R#) rCrtool_progress_callbackz4tool_progress_callback raised on tool.started for %sz tool.startedrtool_start_callbackz!tool_start_callback raised for %sN)r!r#r,time monotonicr7rR)rvitem_idrIr,rYstarteds& r_fire_tool_started>make_codex_app_server_event_bridge.._fire_tool_starteds,,".Ft.L"4(  $DNN,<=GG )+acg%t-CD-I4P R &(KT&t2D? Arc V^8dQhRRRR/#r\r)rs"rrrWsII4IDIrc <\V4pVPR4;'gR;p'dS PVR4MRpVPR4p\V\\ 34;'dV^8pV'd VR, M,V'd$\ P!4V^,, MRp\V4wrxS !RRVRVRR3RVR VR V/R 7Ve V^,M \V4p S !R R V\W4WV3R7R#)rCrN durationMsg@@r^z6tool_progress_callback raised on tool.completed for %sztool.completeddurationrCr=)r,r-tool_complete_callbackz$tool_complete_callback raised for %sr) r#r!popr"r$rr`rarGr,rR) rvrIrbpriorcodex_ms has_codex_msrir=rCr,rYrcs & r_fire_tool_completed@make_codex_app_server_event_bridge.._fire_tool_completeds'-:>((4.:N:NB/Nw/N GT*UY88L)!(S%L9KKh!m -96)_d@PSXYZS[@[jn9$?)+cei'tT:#Xz8XvV X!,uQx2Ed2K)+QSW&t2DG Irc$V^8dQhRRRRRR/#)rrr#rVr2rrr)rs"rrrWs!;;D;;;rcN<\V4pV'dS!W R2V3R7R#R#) raisedrN)r)rrVrrYs&& r _fire_delta7make_codex_app_server_event_bridge.._fire_deltas*6"  TV7+4' : rc V^8dQhRRRR/#r\r)rs"rrrWs 4 4D 4T 4rc<VPR4;'gRp\V\4'd:VP4'd$\ SRR4'dS!RRRRRV/3R 7RSnR #) rrshow_commentaryT_emit_interim_assistant_messagez&_emit_interim_assistant_message raisedrole assistantr@rN)r!r"r2striprI _current_streamed_assistant_text)rvrrrYs& r_fire_agent_message_completedImake_codex_app_server_event_bridge.._fire_agent_message_completedshxx%%2 dC TZZ\\geEVX\6]6] 68`"KDAC E 24.rc$V^8dQhRRRRRR/#)rrr#r@r%rrr)rs"rrrWs!000$040rc<VPR4p\V\4'gR#VPR4;'gRpV\9dV'dSMS!V4R#V'dVR8Xd S!V4R#R#R#)rvNrGrr)r!r"r#_CODEX_TOOL_ITEM_TYPES)rr@rvr"r~rords&& r_on_item4make_codex_app_server_event_bridge.._on_itemsjzz&!$%% HHV$** . .%. !4F F M 96 )$ /7Yr)rVc<S!VRR7#)Fr@rprs&rr4make_codex_app_server_event_bridge..s !u)Er item/startedc<S!VRR7#)Trrrs&rrrs 8A+Fritem/completedc V^8dQhRRRR/#)rnoter#rrr)rs"rrrWstrc&<\V\4'gR#VPR4;'gRpVPR4p\V\4'dTM/pVPR4pV\9;'d\ \ V44pVR 9;'d1\V\4;'dVPR4\ 9pV'g V'dS!RRRV 23R 7SPV4pVe V!V4R#R#) NmethodrrrvrG_touch_activityz_touch_activity raisedzcodex app-server: r>rr)r"r#r!_CODEX_PROGRESS_DELTA_METHODSr%r_CODEX_PROGRESS_ITEM_TYPES) rrrrvis_deltais_itemhandlerrYhandlerss & ron_event4make_codex_app_server_event_bridge..on_events$%% (#))r(#%fd33zz&!::XXtKPVDW?X 8 8 ? ?Zd=S ? ? $>>  w &(@J\]c\dHeGg h,,v&   FO rr)_CODEX_TEXT_DELTA_METHODS functoolspartial) rrtrrVrr~rordrrYrrcs f @@@@@@@r"make_codex_app_server_event_bridgerws35Gb"bdhbb A AII ;; 4 400Oh3Nglf !!+99Ng3H FH^!FH ( O53s#BcV^8dQhRR/#rrrr)rs"rrrs  4 rc\\4;_uu_4VPP4RRR4RVnR# +'giL;i)zRDrop the session so the next turn respawns codex instead of reusing a dead client.N)rr'_codex_sessionclose)rs&r_close_codex_sessionrs5 )   ""$ E  s A A c V^8dQhRRRR/#)ractiver%rtuple[bool, Any]r)rs"rrrs  4 ;K rc\T;'d\VRR44pV'd\VRR4MRpV'dVP4W#3#)z(user_interrupted, interrupt_message); clears the agent-level interrupt so a hard stop cannot poison the next turn (mirrors the conversation-loop finalizer)._interrupt_requestedF_interrupt_messageN)r%rIclear_interrupt)rr interruptedmessages&& r_consume_user_interruptrsKvOO'%1G"OPKRSI"9c22y9JdJrc V^8dQhRRRR/#)rrrrrr)rs"rrrsHHZHDHrc\VRR4\VRR4r2Ve V'gR#\VPRV\V/3R7R#)uhMerge (``None`` clears) the binding into the session row; a failed write only logs — the turn is done.rNrz6codex thread id could not be stored on the session rowr)rIr:patch_session_model_configr)rrrrs&& r_store_codex_thread_idrsHUM48'%W[:\  z"//1i"%99$EFHrcV^8dQhRR/#rr)rs"rrrs 5 5# 5rc :^RIHpVPP4# Tdrp\P RTP \TRR44\TR4TP\4TPP4uRp?#Rp?ii;i)a!``ensure_started`` with the fail-closed resume policy: a stored thread that codex cannot hand back (unknown id, rollout locked by a killed app-server, different thread) is dropped from the session row, the user is told once on the status rail, and a fresh thread starts on the same client.)CodexThreadResumeErrorz,%s; starting a new codex thread (session=%s)rN) )agent.transports.codex_app_server_sessionrrensure_startedr8rqrrIr_emit_diagnostic_status_CODEX_THREAD_RESUME_NOTICE)rrrs& r_start_codex_threadrsQ5##2244 !5Es{{T[\acoquTvwud+ %%&AB##2244 5s"BA&BBBcV^8dQhRR/#rr)rs"rrrsXXJXrc \\VRR4;'gR4P4P4R8wdR#^RIHpT!\\VRR4;'gR44#)acodex's ``[model_providers.]`` for a named custom provider (``providers.``); None means codex's own provider. Only the stable id is sent and codex resolves base_url/env_key itself, so Hermes' credential never enters the JSON-RPC payload (#75186).rrcustomN)codex_model_provider_idrequested_provider)r2rIr|lower"hermes_cli.runtime_provider_customr)rrs& r_codex_model_providerrs] 75*b ) / /R0668>>@HLJ "3wu6JB'O'U'USU#V WWrc V^8dQhRRRR/#)rmodel_providerrrr)rs"rrr's  Z J rc^RIHpV!\VRR44;'gRpV'dVf^RIHpV!VR4pV#)aThe slug codex should run. ``-900k`` picker variants are Hermes-side aliases the backend rejects ("not supported when using Codex with a ChatGPT account"); codex applies the catalog's extended window to the base slug itself. On codex's own provider the slug is bare (``openai/gpt-5.5`` -> ``gpt-5.5``), as for openai-codex; a named custom provider's model ids are its own and pass through.)"strip_codex_context_variant_suffixriN)normalize_model_for_providerz openai-codex)agent.model_metadatarrIhermes_cli.model_normalizer)rrrrirs&& r_codex_wire_modelr's@ H .wugt/L M U UQUE 'K,UNC Lrc V^8dQhRRRR/#)rrirrr)rs"rrr4sZJrc \VRR4p\V\4'd-VPR4RJgVPR4'gR#^RIHp^RIHp^RIH pV!V4pT!T;'gR RVR \VR R4R \VR R4R VPR VP/4wrxVR8Xd3VPR4R8XdRV!\VR R4VR49dR#V#)a``turn/start.effort``: only an explicit Hermes reasoning setting overrides codex's own default, clamped to the route's vocabulary like the Responses path (a level the model lacks fails the turn with 400 "Unsupported value"). ``ultra`` stays ``ultra`` where the model reaches ``max``: codex runs it as its harness mode. Disabled reasoning goes out as ``none`` where the route accepts it.reasoning_configNenabledFeffort)classify_responses_route)route_supported_efforts)_resolve_reasoningrrris_codex_backendis_xai_responsesr&ultrar) rIr"r#r!agent.codex_responses_adapterragent.reasoning_effortragent.transports.codexrrr) rrirrrrrouter_enableds && r_codex_turn_effortr4s u&8$? & - -   +u 48H8L8LX8V8VF>9 $U +E)%++2,j'%UY:ZGE:t46H%J`J`E228F+//9WDTk E:t ,e5GUIJI MrcV^8dQhRR/#rr)rs"rrrOsXXzXrc^^RIHpHpVPV!V4PR44#)a1``turn/start.serviceTier``: the tier Hermes' own Responses path would request this turn (a static ``/fast`` tier pinned in request_overrides, or an open ``auto``/``cold`` window), in codex's words: the OpenAI ``priority`` tier is codex's ``fast``. A tier codex has no word for (``ultrafast``) is not sent.)CODEX_TIER_WORDSeffective_request_overrides service_tier)agent.fast_moderrr!)rrrs& r_codex_turn_service_tierrOs*N    ;E B F F~ V WWrc V^8dQhRRRR/#)rrzlist[dict[str, Any]] | Nonerrr)rs"rrrWs @@+F@RV@rc Z\V4p\V4p\VRR4e7\VRR4pVeWB8Xd\VRR4V8XdR#\V4\VRR4eRM \ V4p^RIHp^RIHpH p^RI H p ^RI H p Rp \\4;_uu_4^R IHp ^R IHp V !4'gV !4p RRR4R p^R IHpV!4pY nW0n^RIHpV!V4;'gRpT!\VRR4;'g\9V!44T V !V !44V!WR7\;V4T;'gR\=W4VVVR7 VnR# +'giL;i \d\,P/R RR7Li;i)aqLazily spawn one CodexAppServerSession per AIAgent (reused across turns, closed by the _cleanup hook). A live session whose thread was started with a different prompt composition (TUI/Desktop ``/personality`` or a prompt mirror mutate the agent in place) is retired first so the new thread carries the current one. Only the FIRST session of an AIAgent resumes the stored codex thread: a retired/recreated one keeps today's fresh-thread behaviour and overwrites the binding once its turn is committed. ``messages`` is the turn's transcript (current user row last); a thread started from scratch is seeded with the prior turns.rN_codex_session_prompt_codex_session_model_provider)resolve_agent_cwd)CodexAppServerSession_ServerRequestRouting)get_configured_codex_binary) load_config)_no_user_can_answer)_get_approval_callbackF)is_approval_bypass_activezLcodex app-server: approval-bypass lookup failed; keeping fail-closed defaultTr)render_history_seed session_cwd)auto_approve_execauto_approve_apply_patch) r&approval_callback codex_binrequest_routingrrrirresume_thread_id history_seed) rrrIrragent.runtime_cwdrrrrhermes_cli.codex_runtime_switchrr rrr'tools.approval_contextrtools.terminal_toolrtools.approvalrr8r9rr agent.codex_runtime_history_seedrr2rrr)rrrrrecordedrrrrrrrrrauto_approve_requestsrrrs&& r_ensure_codex_sessionrWs;5A*51Nu&-95"94@   B$+E3RTX$Y]k$k U#&u.EtLXt^uv{^|3fK- )  >>"$$ 6 8  "t< 9 ;#9*8'D&x088DL1 E=$ / K K37H7J3K_p-km<-@UG3E:5==6~) E=   t cnr sts+!E2 F2 F "F*)F*c V^8dQhRRRR/#)rrlist[dict[str, Any]]rr%r)rs"rrrs7KPTrcVP'gR#^RIHpVPp\VRR4pV^,pVe6VP R4R8Xd VP R4V8Xd VR,pVF pV!W'4K \VR R4fR#RpVP V4pVRJd"\PR \VRR44VR J# \ d\PR R R 7LOi;i)aSplice the projected messages into ``messages`` and flush them to the session DB; True when the rows are durable in the session DB (the codex thread binding may then be published). Bypasses conversation_loop's per-step _persist_session(); the flush dedups via _DB_PERSISTED_MARKER so only the new codex rows are written. The agent stays the sole persister (agent_persisted=True): a gateway re-write would re-INSERT the user turn.F)append_messagesubmitted_user_textNrzuserr@:NNrz/codex app-server projected-message flush failedTrucodex app-server turn was delivered but could NOT be persisted to the session DB (session=%s) — this turn will be missing after restart/resumer) projected_messagesagent.message_metadatarrIr!_flush_messages_to_session_dbr'r8rq) rrrrrrfirstprojected_messageflush_oks &&& r_persist_projected_messagesrs   " " "500"$(=tD q !E'EIIf,=,G )$(;;/3/x30umT*2HY66x@5YZabgiuw{Z| ~ t  YHSWXYsC"C<;C<c(V^8dQhRRRRRRRR/#) rrroriginal_user_messagershould_review_memoryr%rrr)rs"rrrs,.B^a-16Drc |\VR^4VP,Vn\W4\ WVR7p^VP u;8;'dVP8*Mu;'dRVP 9pV'd^VnVP'g>VPf0\\VRR4R\W1PRVR7R 7VP'dPVP'g>V'g V'd.\\VR R4R \\V4WFR 7R 7V#) zPPost-turn bookkeeping mirroring the chat_completions loop; returns usage fields._iters_since_skill)r skill_manageN_sync_external_memory_for_turnzexternal memory sync raisedF)r final_responserr)r-_spawn_background_reviewzbackground review spawn raised)messages_snapshot review_memory review_skills) rItool_iterationsr#rr_skill_nudge_intervalvalid_tool_namesrr<r:r# final_textrl)rrrr r! usage_resultshould_review_skillss&&&$$ r_finish_codex_turnr1s  'u.BAFI]I]]E'41%QL ; ;WWu?W?WWII .%2H2H H#$     2ge%EtLNktx"7eju}u   t///5IMage%?FHhqu"8n CQ rc XVwrxRVRVRVRVRV'*RV/V'dRV/M/CRV/CVC#) zVResult shape shared with the chat_completions path (``partial`` == ``not completed``).r&rr:r@rrinterrupt_messager<r) rCrr:r@r<r&ruser_interruptedrGs &&$$$$, rrArAs`+4'.*h YY y=-IY 8I !2 3b      rc(V^8dQhRRRRRRRR/#)reventrrIr2rrr)rs"rrrs(3333333rc\WR4pVf(\V\4'dVPW4pVeV#T#)zKField access for attr-style (SDK objects) and dict (raw JSON) events/items.N)rIr"r#r!)rJrIrr*s&&& r _event_fieldrLs= E &E }E400 $(%5272rc V^8dQhRRRR/#rrJrrr%r)rs"rrr$s  C D rcNa\VR4pV\9d\\VR44#VR8Xdq\VR4oR\\SR4;'gR49;'d;\;QJdV3RlR 4F 'gK R# R #!V3RlR 44#R #) zWhether a Codex Responses event carries substantive forward progress. Lifecycle/keepalive frames and empty structural deltas prove transport liveness, but do not mean the model has begun producing its response. rGrresponse.output_item.addedrv function_callrc3N<"TFp\\SV44xK R#5ir)r%rL)rfieldrvs& rr+_codex_event_has_content../s&Pa9_DdE* + +9_s"%TF)rCrcrIr*)rL_CODEX_PROGRESS_DELTA_TYPESr%r2any)rJ event_typervs& @r_codex_event_has_contentrX$s eV,J00L01111E6*#l4&@&F&FB"GGaaCCPa9_PaCC aC aCPa9_PaMa a rc V^8dQhRRRR/#rrJrrrr)rs"rrr4s ] ]s ]t ]rcaa^RIHp\SR4oRVV3RllpV!R4pVe \V4MRP 4;'gRpV!WB!R4V!R4R 7h) zRaise ``_StreamErrorEvent`` from a ``type=error`` SSE frame. The spec puts code/message/param at the top level, but the SDK and several proxies nest them under ``error``; read top-level first, then the envelope.)_StreamErrorEventr<c V^8dQhRRRR/#)rrIr2rrr)rs"rr)_raise_stream_error..__annotate__:s]]3]3]rcH<\SV4pVfSe \SV4#T#r)rL)rIr*rJnesteds& r _error_field)_raise_stream_error.._error_field:s+UD)-2]v?Q|FD)\W\\rrzstream emitted error eventcodeparam)rcrd) run_agentr\rLr2r|)rJr\ra raw_messagerr`sf @r_raise_stream_errorrg4st, % )F]]y)K#.#:s;@\cceFFjFG G,v*>lSZF[ \\rc V^8dQhRRRR/#)rrvrrrr)rs"rrrBsEEEErc\VRR4p\V\4'dVP4P 4#R#)phaseN)rLr"r2r|r)rvrjs& r_message_phaserkBs6 w -E$.uc$:$:5;;=   DDrc V^8dQhRRRR/#)rrvrrr2r)rs"rrrGs##rc\VR.4p\V\4'dTM.pRPRV44P 4#)zSConcatenated ``output_text`` parts of a message item ("" if content is not a list).r@rc3"TF9p\VRR4R8XgK\\VRR4;'gR4xK; R#5i)rGr output_textrN)rLr2)rparts& rr"_output_text_of..KsC>Cd|TXZ`bdGeivGv1Lvr * 0 0b11esAAA)rLr"rlrQr|)rv content_partspartss& r_output_text_ofrtGsH y"5M' t<C  egrcB]tRtRt$RtR;t;tt^tRt R] R&Rt R] R&R t R ] R &R;t ;t;ttRtRtR tR RltRRltRRltRRltRRltRRltRRltRRltRRltRR R!]R"]R#]R$]R%]R&]/tR']3R(]3R)]33tR*R+ltR,R-lt R.R/lt!R0t"R#)1_CodexResponseAssembleriPuAssemble a Response-shaped ``SimpleNamespace`` from raw Responses SSE events. Only ``usage`` / ``status`` / ``id`` / ``service_tier`` are read from the terminal frame — never ``response.output``. Output items come from ``output_item.done``, or are synthesized from text deltas, or settled from function calls announced via ``output_item.added`` but never confirmed (some backends omit per-item done events on success).FNractive_message_phaseractive_summary_indexr@r2terminal_statusc WVuVnVnVnWEuVnVn.Vn..uVnVn..uVnVn /Vn /Vn R#r) ri on_text_deltaon_reasoning_deltaon_commentary_messageon_first_delta output_itemsoutput_indexesoutput_sequences text_deltascommentary_text_deltaspending_function_callsannounced_output_order)selfrir{r|r}r~s&$$$$$r__init__ _CodexResponseAssembler.__init__bskBGXj? D&(?:O7"D$7')682T28:B5$5BD#8:#rc(V^8dQhRRRRRRRR/#) rcbr0labelr2r,rrrr)rs"rr$_CodexResponseAssembler.__annotate__os.EEEECEDErc *\VRV R2VR7R#)z Codex stream rsrN)r:)rrrr,s&&&*r_safe_CodexResponseAssembler._safeosbM%8tDrc$V^8dQhRRRRRR/#rrJrrWr2rrr)rs"rrrrs!CSTrc  L\VR4p\VRR4pVR8Xd \V4MRVnVPR8Xd.Vn\ \VRR44pV'dOWPP 9d?VP \VR43VP V&V;P ^, unR\ V49d^R VnV'dMVP V,wrgRTR \ \VR R4;'gR4RVR V/VPV&R#R#R#) rvrGrrN commentaryrC output_indexrQTr*sequence) rLrkrwrr2rnext_output_sequencehas_tool_callsr)rrJrWrvr"rbannounced_sequenceannounced_indexs&&& r_on_item_added&_CodexResponseAssembler._on_item_addedrsE6* vr2 .s*E1T#N3|C1T$ $)rnextrr)rrbrs&&fr_pending_function_key-_CodexResponseAssembler._pending_function_keysN 11 1N  #E1L1L1R1R1TEFJL Lrc$V^8dQhRRRRRR/#rr)rs"rrrs! 6 6s 6 6 6rc  RVnVP\\VRR44\VR44pVPP V4pVfR#RV9d-TR;;,\VRR4;'gR, uu&R#VP R4'd$\VRR4;pe\V4VR&R#R#R#)TrbrrNrr*zfunction_call_arguments.done)rrr2rLrr!endswith)rrJrWrr done_argss&&& r_on_function_call)_CodexResponseAssembler._on_function_calls"((\%B-O)P)5e^)LN--11#6 ?  j K L$D$J$J J  !? @ @*%dCC P'*9~ $QArc$V^8dQhRRRRRR/#rr)rs"rrrs& R R R# R$ Rrc \VRR4pV'dVPfR#\VR4pVe*VPeW@P8wdRV 2pW@nVPVPRV4R#)rrN summary_indexrr|)rLr|rxr)rrJrWreasoning_textrs&&& r_on_reasoning_delta+_CodexResponseAssembler._on_reasoning_deltast%eWb9!8!8!@ $UO<  $((4JcJc9c#''7!8(5 % 4**,@.Qrc$V^8dQhRRRRRR/#rr)rs"rrrs!.-.-3.-C.-D.-rc a\VR4pVfR#SPPV4\\VRR44pSPP VR4wrV.pR\\VRR449Ed.\VRR4p\ V\4'dVP4'dSPP4U U u.uF!wr\V R,R4V8XgKV NK# pp p V'gNSPV\VR44p V e.\SPV ,R,R4'gV .pRRreM#SPV\VR44p V eV .pV'd*\V3RlV4R R 7p V R ,V R,reVf&SPSP^,upSn SPP\VRV44SPPV4VFp SPPV R4K! \!V4R 8Xd{SP"ekRP%SP&4P4;'g \)V4p V 'dSP+SP"R V 4.SnR#R#R#uup p i)rvNrCrrQrGrcrc3J<"TFpSPV,xK R#5ir)r)rrrs& rr8_CodexResponseAssembler._on_item_done..s!&`S_Ct'B'B3'G'GS_s #cVR,#)rr)rs&rr7_CodexResponseAssembler._on_item_done..s '*:Mrrrrr}NN)rLrrFr2rr!r"r|rrrrminrrrrkrkr}rQrrtr)rrJrW done_itemdone_idrr pending_keys done_call_idrr pending_keyannounced_aliascommentary_textsf&& r _on_item_done%_CodexResponseAssembler._on_item_dones /      +l9dB78.2.I.I.M.MgWc.d+ c,y&""EF F' 9bAL,,,1C1C1E1E9=8S8S8Y8Y8[ ]8[ #/#K|#[!$8[  ]$"&"<"( ) $ 49S9S9_ ggd&A&ABHHJhho^gNhO 4557NP_`*,D ' :` 47 ]s K 8K c$V^8dQhRRRRRR/#)rrJrrWr2rr%r)rs"rrrs!#34rc RVn\VR4pVe\VR4\VR4uVnVn\VR4Vn\VR4p\ V\ 4'dW@nVR8Xd\VR4VnMVR8Xd\VR 4Vn VP;'gVR 8HVn VP;'gVPR 4VnR#) TresponserrCrrresponse.incompleteincomplete_detailsresponse.failedr<response.completedz response.) saw_terminalrLterminal_usageterminal_response_idterminal_service_tierr"r2ryterminal_incomplete_detailsterminal_errorsaw_response_completed removeprefix)rrJrWresp_objrstatuss&&& r _on_terminal$_CodexResponseAssembler._on_terminals z2  =I(T[=\^jksuy^z :D !:)5h)OD &"8X6G'3'''.$223?J^3_000&28W&E#&*&A&A&g&gZSgEg##33[[z7N7N{7[rr<c \V4#r)rg)rrJrWs&&&rr _CodexResponseAssembler.s 1DU1KrrPzresponse.output_item.donerrrresponse.refusal.deltac RV9#)zoutput_text.deltarts&rrrs &!+rc RV9#)rQrrs&rrrs \]I]rc &RV9;'dRV9#)rrrrs&rrrs;!#441 4rc V^8dQhRRRR/#rNr)rs"rrrsXX#X$Xrc a\VRR4o\S\4'dSMRoVPP S4;'g!\ V3RlVP 4R4pVe\V!WS44#R#)z=Process one event; True when the stream hit a terminal frame.rGrc3L<"TFwrV!S4'gKVxK R#5irr)rrhrWs& rr/_CodexResponseAssembler.feed..s ?tNbdafghrfsNbrNF)rLr"r2_EXACT_HANDLERSr!r_FUZZY_HANDLERSr%)rrJrrWs&& @rfeed_CodexResponseAssembler.feedss!%4 #-j##>#>ZB &&**:6{{$?tdNbNb?tvz:{9@9LtGD45WRWWrcV^8dQhRR/#)rrz list[Any]r)rs"rrrs///rc &\\VPVPVP44pVP P 4FpVR,pTPVPR4VR,\R\VRR4\VRR4\VRR4R VR ,;'gR P4;'gR R 734K \;QJdRV4F 'dK RM RM !RV44'd5\\4;_uu_4VPRR7RRR4MVPRR7VUu.uF qD^,NK up# +'giL(;iuupi)zCMerge .done items with settled pending calls, keeping stream order.rvrrrQrCNrcrIr@r*rz{})rGrCrcrIrr*c36"TFq^,RJxK R#5ir|r)rentrys& rr:_CodexResponseAssembler._settled_output..,s9Qxt#sFTcV^,#)r}rrs&rr9_CodexResponseAssembler._settled_output...suQxrrcV^,#)rrrs&rrr0s58r)rlziprrrrvaluesrFr!rrLr|allrr5sort)rindexedrrvrs& r_settled_output'_CodexResponseAssembler._settled_outputs>s4..0E0EtGXGXYZ2299;G6?D NNGKK79Lo$dD$)GQ]^bdmosQt!$5k#;/552<<>FF$ O < 39933399 9 9)$$ !7 8%$ LL3L 4&-.gUag.. %$/s3E;'F; F cV^8dQhRR/#)rrrr)rs"rrr3sPPPrc  fVP'dVP4M\VP4pV'g\VP'dJVP 'g8\ RRPVP4R7.p\ RRRVR7.pVP'gV'g \R4h\ VRPVP4VPVPVPVPVPVPVP R7 #) ror)rGrrr{r@)rGrzrr@z7Codex Responses stream did not emit a terminal response) rarorrrCrirr<r)rrrlrrrrrQr RuntimeErrorrryrrirrr)rrar@s& rr=_CodexResponseAssembler.result3s7;6Q6Q6QD002W[\`\m\mWn$***43F3F3F&MHXHX@YZ[G%9;{dklmF   XY Yrwwt/?/?'@H[H[dhdxdx(( tOoOo%%D4N4NP Pr)rwrxrrrrrirr}r~r|r{rrrrrrrrrrryrr)#rH __module__ __qualname____firstlineno____doc__rrrrrw__annotations__rxryrrrrrrrrrrrrrrrrrrrrr=__static_attributes__rrrrvrvPsu 9>=N=&'+*+ $#$&OS&[__N_)_,G. " ;E*H,2 6 R.-`( K$n6QS`l,Aq 46IJO X/(PPrrvr{r|r}r~rinterrupt_checkc$V^8dQhRRRRRR/#)r event_iterrrir2rrr)rs"rrrDs&"rcN\WVWER7pVFIp Ve V!V 4VeV!4'gVP V 4'gK:VP4# VP4# \\3dh\d\P RRR7Li;i)aConsume a Codex Responses SSE stream into a Response-shaped ``SimpleNamespace`` (see :class:`_CodexResponseAssembler`; ``status`` is ``completed`` when the stream ended with content but no terminal frame; ``model`` comes from kwargs). Callbacks: ``on_text_delta`` per output_text delta, suppressed once a function_call is seen; ``on_reasoning_delta`` for reasoning and ``phase=analysis`` deltas (also commentary without a commentary callback); ``on_commentary_message`` once per completed ``phase=commentary`` message, before any following tool item; ``on_first_delta`` one-shot; ``on_event`` every event before any processing; ``interrupt_check()`` True breaks the loop and may raise ``TimeoutError`` / ``InterruptedError`` for request retirement that must not become a partial final response.)rir{r|r}r~z!Codex stream on_event hook raisedTr)rv TimeoutErrorInterruptedErrorr'r8r9rr=) rrir{r|r}r~rr  assemblerrJs &$$$$$$$ r_consume_codex_event_streamrDs(eew>StI   Q  'O,=,=)..QVBWBW          !"23  Q @4 P QsA..B$ B$#B$c$V^8dQhRRRRRR/#)rrrr?rrr)rs"rrras!C.^rc \V4p\VRR4p\V4'd\V!44'gV#RV9dR.M.pVP RR4VP R4p\ V\4'diRV9dbVP4UUu/uFwrgVR8wgKWgbK uppVR&VR,'gVP R4VPR4V'dB\PRVP R\VRR44R PV44V#uuppi) zDrop fields the ChatGPT OAuth Codex endpoint rejects, at the final wire boundary (after Relay / middleware / ``request_overrides``): a late ``prompt_cache_retention``, top-level or nested in ``extra_body``, would otherwise HTTP 400 a valid follow-up._is_codex_backendNprompt_cache_retentionz top-level extra_bodyz^Dropped unsupported prompt_cache_retention at consumer Codex wire boundary (model=%s, via %s).rirr0) r#rIrr%rkr!r"rrrFr8rqrQ)rr? sanitizedbackend_predicate dropped_fromrkvs&& r _sanitize_consumer_codex_requestrasW I':DA & ' 'D1B1D,E,E$< $IK=rL MM*D1|,J*d##(@J(N4>4D4D4F"h4FDA!OgJg4144F"h ,&& MM, 'L)w }}WgeWi.PQSWS\S\]iSj l #is ! D:1D:c V^8dQhRRRR/#)rrYr#clientrr)rs"rrrysY2Y2Y2cY2rc` aaaaaaaaaaaaaa a!a"^RIp^RIHo^RIHpVP VP VPVP\3o S;'gSPRR7o^SPR4uoo.Sn \P4o!S!e S!PM \SRR4oRRR RR R /o"R VV3R lloRVVV"3RlloRV3RllpRVV3RllpRVV3RllpRVVVVV!3Rllp RVV3Rllp RVV3Rllp RVVVVV"3RlloRVVVVV"3Rllp R VVVV V"3R!llp R"VVV3R#llp\SR$R%4p\SR&R4RJ;'dTpV'dV!SP 4MRp\SR'R 4'dR(M(\#\SR)^4;'g^4^8dR*MR+p\%S^,4EFgoS!4'g \'R,4hSP('d \+R-4hS^8dS!eS!P,'dwS!P.;_uu_4\0P0!4S!nRS!nRS!n\8P;R.S!P2S^,S^,S4RRR4.oR;S"R&;S"R &pR S"R &TP=\?S4T \A\SR/R04;'gR04\A\SR1R04;'gR24\AS;'gR04VV3R3lV SPBR4R5R6R7R8VR9SR:\SR;R4/R%R<7 p\ETSV!V4V!SPF4TVe V!V4MRV!V 4V R=7pSP('g T !T4TPXRC9da\8P[RATPXTP\TP^\aRBSP44SPK44TTfT!S"PR 44u#T!T4u# R# +'giEL;i S dpSS8d S!T4h\8PITfR>MR?S^,S^,SPK4T4S'g\MSS^,S^,4oRp?TfT!S"PR 44EKT!T4EK$Rp?i\NdKTeETPPe7TPPuTfT!S"PR 44u#T!T4u#hSdpSS8dS"R,f\STPTTPV4'dc\8PIR@S^,S^,SPK4T4Rp?TfT!S"PR 44EKT!T4EKS!T4hRp?ii;i TfT!S"PR 44iT!T4i;i)DzVOne streaming Responses API request over raw ``responses.create(stream=True)`` events.N)APIConnectionError) relay_llmcodex_stream_directreasonri"_active_codex_stream_request_tokenr* raw_streamsuperseded_loggedFcV^8dQhRR/#rrr%r)rs"rr&run_codex_stream..__annotate__stttrc:<SRJ;'g\SRR4SJ#)Nr()rI)r request_tokensr_request_is_current-run_codex_stream.._request_is_currents'$ss7[]a(bfs(ssrcV^8dQhRR/#r,r)rs"rrr-s   rc<SR,pVe\SV4'dR#SR,'g,RSR&\PRSPRR44R#)r*Tr*zCodex streaming attempt superseded by a newer stream; suppressing its live deltas while consuming to completion so the final response is not truncated (model=%s).rirF)r r8rqr!)tokenrrY writer_tokens r_writer_is_current,run_codex_stream.._writer_is_currents^W% =4UEBB/0004L, - NNh%>>'9= ?rc V^8dQhRRRR/#)rr/zCallable[[Any], None]rr)rs"rrr-s JJ)J.CJrc<aVV3Rl#)zIWrap a callback so a retired request's late frames never reach the agent.c2<S!4'd S!V4#R#rr)r*r0r/s&rr3run_codex_stream.._fenced..s*=*?*?RYITIrr)r/r0sfr_fenced!run_codex_stream.._fenceds IIrc V^8dQhRRRR/#)rr/zCallable[..., None]rr)rs"rrr-s cc%c*=crc<aVVV3Rl#)ziWrap a live-display callback so a superseded writer's frames never reach the sink (retired ones neither).cH<S!4'dS!4'dS!V!#R#rr)r,r0r6r/s*rr1run_codex_stream.._live..s$*=*?*?DVDXDXRYb^bbrr)r/r0r6sfr_liverun_codex_stream.._lives bbrc V^8dQhRRRR/#)rrr2rrr)rs"rrr-s++S+T+rc~<SPPV4S!4'dSPV4R#R#r)_codex_streamed_text_partsrF_fire_stream_delta)rr6rs&rr(run_codex_stream.._on_text_deltas3 ((//5     $ $T * rc V^8dQhRRRR/#rZr)rs"rrr-s;;;;rcV<\P!4p\SRR4fVSn\V4pR;r4S eiS P;_uu_4S P RJpVS nV'd/S P RJpVS nS P'dRS nRRR4V'd(\PRVS^,S^,S4V'd(\PRVS^,S^,S4SPR4R# +'giL;i)_last_api_first_chunk_atNFzACodex stream first parsed event at %.3f (attempt=%s/%s, model=%s)zICodex stream first substantive progress at %.3f (attempt=%s/%s, model=%s)zreceiving stream response) r`rIrKrXlock last_event_tslast_progress_ts phase_awareretry_started_tsr8rr) rJnow has_progress first_eventfirst_progressrrZmax_stream_retriesriwatchdog_states & r _on_event#run_codex_stream.._on_eventsiik 54d ; C-0E */6 ',,  %$$$,::dB /2,%3%D%D%LN69N3%111:>7%  KK[Wq["4q"8% A  KKcWq["4q"8% A 9:%$sADD D( cV^8dQhRR/#r,r)rs"rrr-s00d0rc^<S!4'g \R4h\SP4#)z?Codex Responses stream request retired before terminal response)rr%r)r0rsr_interrupt_or_superseded2run_codex_stream.._interrupt_or_supersededs+#$$`a aE..//rcV^8dQhRR/#)rnext_api_kwargsrr)rs"rrr-s ] ]N ]rc <^RIHpT!\SRR4\\SRR4;'gR44'd \ R4h\ SV4pRVR&SP P!R/\V4B#) r})is_actual_routerrrzFActual requests require Chat Completions; refusing to call /responses.Tstreamr) hermes_cli.providersr`rIr2r~r responsescreater )r^r` stream_kwargs active_clientrs& r_open_codex_stream,run_codex_stream.._open_codex_streams8  E:r *  z26<<" =  X 9P "& h&&--\0L]0[\\rc V^8dQhRRRR/#)rrr=rrr)rs"rrr-s e e- eD erc d<\V4wr\PRVfRMT\SR,RJ4P 4V\ SRR4S^, RS^, 24SR,f9\ STS^,\ SRR4;'g\ SRR4R7R#R#) zxCodex Responses request failed: serialized_request_body_bytes=%s stream_opened=%s exception_chain=%s model=%s attempt=%sNrr*ri/rr)r[r)rWr8rqr2rrIr )rrRexception_chainrfrrZrUr5s& r _log_failure&run_codex_stream.._log_failures.LS.Q+@N`NhoA<0<=CCEX_`egnpyXz!A+a(:Q(>'?@ B  ( +sWq[  DAccWUT^`bEc e )rc V^8dQhRRRR/#)r _raw_streamrrrr)rs"rrr-s883848rcz<\S4SR&VSR&\PRS^,S^,S4R#)r*r)z-Codex stream opened (attempt=%s/%s, model=%s)N)r r8r9)rprrZrUrir5s&r_codex_stream_created/run_codex_stream.._codex_stream_createds< 3E : W%0 \" D aK+a/ 8rc V^8dQhRRRR/#r event_streamrrrr)rs"rrr-s@@3@4@rc<aa\4pV^8:dR#^RIHpV!\S P R4RR44oSf'\ PRS P44R#\P!4oRVV3Rllp\P!W4pRVn R Vn VP4VFpK VP%4VP&eVP)4SP4'd(\ P#R TS P44R#R# \ dRoELi;i .S OS N5d`pSP4'g@\!TS 4'g S !T4\ P#R S P4T4Rp?LRp?i\ d\ PR R R 7ELi;i TP%4TP&eTP)4ii;i)r}N)_socket_from_responser)rzKCodex post-terminal drain skipped: no interruptible stream socket found. %scV^8dQhRR/#rr)rs"rrDrun_codex_stream.._drain_for_finalizer..__annotate__s # #T #rcD<SP4^RIHpV!S4R#)r})_shutdown_socketN)rBagent.agent_runtime_helpersr|)r|sock timed_outs r _wake_ownerCrun_codex_stream.._drain_for_finalizer.._wake_owners MMO E T "rzcodex-post-terminal-watchdogTzCodex Responses stream transport finalization failed after a terminal response was already received; returning the completed response instead of retrying. %s error=%szDCodex Responses stream finalization failed after a terminal responserzCodex Responses stream remained open %.1fs after a terminal response (agent.stream_drain_timeout); shut down its socket and completed cleanup on the owner thread. %s)r+r}rxrIr!r'r8r9_client_log_context threadingEventTimerrIdaemonstartis_setr"rqcancelidentrQ)rvbudgetrxrwatchdog_ignoredrr~r_APIConnectionErrorrmrtransport_errorsr5s& @@r_drain_for_finalizer.run_codex_stream.._drain_for_finalizers '( Q; E (1A1A,1OQ[]a)bcD < LLf224 6 OO%  # #??676  NN ()& OO ~~)       NNs113  ] D 28!7#67 ##%%!#'788 %b--/  p LL_jnL o p OO ~~) *sN"D4.E4 EE GAF.)G. G;GGGG1H c V^8dQhRRRR/#rur)rs"rrr-0s f f# f$ frc<\VRR4p\V4'd V!4R#R# \dSeSPSRR7R#R#i;i)rNcodex_stream_close_failedr&)rIrr'_abort_request_openai_client)rvclose_fnrfrr!s& r_close_event_stream-run_codex_stream.._close_event_stream0s^<$7 f!! " f!22=Id2e"  fs,"AArxTinterim_assistant_callback is_subagent delegated_fallback_indexfallbackprimaryz3Codex Responses stream request retired before retryz+Agent interrupted before Codex stream retryz=Codex physical stream retry at %.3f (attempt=%s/%s, model=%s)rrrcodexc0<\\S4SR7#))ri)rrl)intercepted_eventsrisrr"run_codex_stream..Ws&A$GYBZbg&hrcV#rr)chunks&rrrYsrc^\\VR4;'d\VR4'*4#)ra__iter__)r%r)rs&rrrZs%48@T@s@s]defhr]sYs;trapi_modecodex_responses call_role retry_countapi_request_id_current_api_request_id) rrI model_name finalizeron_stream_createdon_chunk chunk_adaptercompleted_response_predicatemetadatadefer_logical_completion)rir{r|r}r~rr zLCodex Responses stream connect failed (attempt %s/%s); retrying. %s error=%sz\Codex Responses stream transport failed mid-iteration (attempt %s/%s); retrying. %s error=%szPCodex Responses pre-stream connect failed (attempt %s/%s); retrying. %s error=%szbCodex Responses stream terminal status=%s (incomplete_details=%s, error=%s, streamed_chars=%d). %sc38"TFp\V4xK R#5ir)rD)rrs& rr#run_codex_stream..s"T3Sa3q663Ss>failed incomplete)1httpxopenair#rr$RemoteProtocolError ReadTimeout ReadError ConnectErrorConnectionError_ensure_primary_openai_clientr!rFrr4rI_fire_streamed_codex_commentaryr$rangerrrrOrLr`rPrMrNr8rrar#r2rFr_fire_reasoning_deltar9rryrr&r"rNTransportErrorrrqrr<sum)#rrYr!r~_httpxr$r<rBrrWr[rgrrrrrxwants_commentaryr}rrvfinalrrrmr0r6rfrZrrUrir/rrVr5s#fff& @@@@@@@@@@@@@rrun_codex_streamrys@22F4F4FHXHXZ`ZmZmo~__eAAI^A_M !:>>'#:-/E$/224N  %  U@$ GT<7JERLtt  JJcc++ ;;400 ] ] e e88@@D f fe%6=Ou&BDIQUUiiZiL\E%"G"GHbf '}e D D$'7H!(L(Q(QPQ$RUV$Vj\e+a/0"$$TU U  % % %"#PQ Q Q;>5.:T:T:T $$$26))+//3,26/ ["33Wq[BTWXBXZ_a % $&LPP WP \ :\,1 ()A 21 (//$&8"75,#C#I#IrJWUJ;FFwGTWX]XcXcacTdh&;FXF_F_"51t(*;[)Ubdk.?XZ^0_a-1 0  4 W^=T',U-H-H'Iav##L$4$4\$BC#L1C  + 0K0K0W'6666##L$4$4\$BC#L1;&  00\'5J5R&s}}f6K6KLLLLj! %7!%;U=V=V=XZ]##L$4$4\$BC#L1!S! 2##L$4$4\$BC#L1sAQ rrrrr))zitem/agentMessage/deltarG)zitem/reasoning/deltar)zitem/reasoning/summaryDeltar)zitem/reasoning/textDeltar)zitem/reasoning/summaryTextDeltar)T>response.text.deltaresponse.audio.deltarresponse.output_text.deltaresponse.reasoning_text.delta%response.reasoning_summary_text.delta&response.function_call_arguments.deltar)rrrDr)[__conditional_annotations__r  __future__r contextvarsrrmloggingosrr` contextlibrtypesrtypingrrrragent.stream_single_writerr r (agent.transports.hermes_tools_mcp_serverr agent.sdk_transform_bypassr agent.stream_diagr rr getLoggerrHr8 ContextVarrr r(r+r:rWryrrrr frozensetrrrrr!rPr+r4rrr#r,r7rGrRrrrrrrrrrrrrrrrr1rDrArLrUrXrgrkrtrvrrr__all__)rs@rrsnA#   !,,TQC=/   8 $@K@V@VDA=!$)&:UW:os:>."1J   CCNL'TX'hm'`##tu!*)R8Q)R R')FV!4~{6SS)., Wbdpq)6<O%'89%y+wG1 KG R  0l`L  ")VKH 5X 6X@FD2+SX+\ $3()  ]E qPqPh26KOgk"&8<:0Y2x r