+ iHj[*Rt^RIHt^RIt^RIt^RIHtHtHtH t ]P!] 4t Rt RRltRRltRR ltR R ltR R/R RlltR R/RRlltRtRRltRRltRRltRRlt.ROtR#)uStream diagnostics — per-attempt counters, exception chains, retry logging. When a streaming request dies mid-response these helpers record WHY (which CF edge / OpenRouter downstream served it, bytes+chunks before the drop, HTTP status, underlying httpx error class) to ``agent.log`` in full and to the user-facing status line compactly. ``run_agent`` keeps thin forwarders so existing call sites and tests patching ``run_agent.`` keep working. ) annotationsN)AnyDictListOptionalcV^8dQhRR/#)returndict[str, Any])formats"6/home/ubuntu/.hermes/hermes-agent/agent/stream_diag.py __annotate__rs.cLR\P!4RRR^R^R/RRRRR R /#) zkFresh per-attempt diagnostic dict; mutated in place by the streaming functions and read by the retry block. started_atfirst_chunk_atNchunksbytesheaders http_statusserving_providerfinish_reason_seenF)timer rr stream_diag_initrs< diik#3T8QQR2}d,> e  rc(V^8dQhRRRRRRRR/#)ragentrdiagr http_responser Noner )r s"r rr$s*   > RU Z^ rcVe\V\4'gR#\VRR4VR&\VRR4;'g/p/p\F3pVP V4;p'd\ V4R,WE&K3K5 WAR&R# \dLji;i \dK\i;i \dR#i;i)zkSnapshot headers + HTTP status at stream open (so they survive a drop before the first chunk). Best-effort.N status_coderr:NxN) isinstancedictgetattr ExceptionSTREAM_DIAG_HEADERSgetstr)rrrrcapturednamevals&&& r stream_diag_capture_responser-$sJtT$:$: %m]DI]  -D9??R#%'D !++d++3+%(Xd^HN,( #Y          sLB B.B.-B? B. BB B+'B.*B++B.. B=<B=c V^8dQhRRRR/#)rerror BaseExceptionr r)r )r s"r rr:sRR=RSRrc>a.pTpVeX\V4^8dHW!9dBVPV4\VRR4;'g\VRR4pVeW2JdMTpK[RRloV'dRPV3RlV44#\ V4P #)a!Compact ``Outer(msg) <- Inner(msg) <- ...`` rendering, walking ``__cause__`` then ``__context__`` (deduped, max 4 deep): the OpenAI SDK wraps httpx errors so only the wrapper class is visible at the catch site; the inner RemoteProtocolError/ConnectError/ReadError says WHY the stream died.N __cause__ __context__c V^8dQhRRRR/#)rer0r r)r )r s"r r-flatten_exception_chain..__annotate__GsII-ICIrc\V4P4PRR4p\V4^8dVR,R,MTpV'd\ V4P RV R2#\ V4P #)  :NN…())r)stripreplacelentype__name__)r5msgs& r render'flatten_exception_chain..renderGsg!flln$$T3/#&s8c>c$i%s/2$q'""#1SE+HQ8H8HHrz <- c34<"TF pS!V4xK R#5iNr ).0r5rDs& r *flatten_exception_chain..Ls/$Qvayy$s)r@appendr%joinrArB)r/seenlinknxtrDs& @r flatten_exception_chainrP:s!#D$)D  s4y1}1A DdK.TT'$ t2T ;#+ I 486;;/$/ /QT%[=Q=QQrc V^8dQhRRRR/#)rrOptional[dict[str, Any]]r tupler )r s"r rrOsqq/qEqrc^;rRpR;p;p;rgRp\V\4'Ed\P!4p \VP R4;'g^4p\VP R4;'g^4p\ VP R4;'gT 4p \ RW, 4pVP R4p V e!\ R\ V 4V , 4R R 2pVP R 4;'g/p \V \4'd/V 'd'R PR V P444pVP R 4e\VP R 44pVP R4'd\VR,4p\VP R44pWaW#WGW3# \dLi;i)z(http_status, bytes, chunks, elapsed, ttfb, serving_provider, finish_reason_seen, upstream) for the retry log line; ``-`` when unknown.-Frrrrz.2fsrr9c34"TFwrV RV 2xK R#5i)=Nr )rHkvs& r rI_diag_fields..bs(PA3assrrr) r#r$rintr(floatmaxrLitemsr)boolr&) r_bytes_chunks_elapsed_ttfb _headers_repr _http_status_serving_provider_finish_reason_seen_now_started_firstrs & r _diag_fieldsrmOsFH?BBEBMBL$ 99;D'*//a0F$((8,112GTXXl3;;t4 0 7 7CHY[\9] NN ! !c5>>#8#8S K ( 6B$5G #M2  "5zH "  *%[))F * D 3d CDshCD D C.&D/ DD%+DC+(D*C++D. DDDD"D:9D:c4V^8dQhRRRRRRRRRR R R R R /#)rrrr/r0rpr]rqrrrarrRr rr )r s"r rrsF   ' 25 EH  7   rc@V'dRMRp\WWW4VR7VP;'gRpRp\V\4'dVP R4MRp V e5R\ R \ P !4\V 4, 4R R 2pTPR T R T R\T4P RT RT RT R2 4TPRT RT R\T4P 24R# \dLti;i \dR#i;i)zOne compact user-visible status line for a stream drop+retry, plus the full WARNING via log_stream_retry. ``after Xs`` distinguishes "couldn't connect" (0s) from "died mid-stream" (idle-kill / proxy timeout).zdrop mid tool-calldrop)ror/rprqrrrr|rN after rUz.1frWu⚠️ z stream z (r=u — attempt /z dropped, reconnectingz stream retry ) rr|r#r$r(r_rr^r&_buffer_diagnostic_statusrArB_touch_activity) rr/rprqrrrror|_suffixstarteds &$$$$$ r emit_stream_droprs- $1 fD \uy~~++HG ,6tT,B,B$((<(  CuW~)E FsK1MG  ''hZxvRU 0D0D/EQwiP")1\N2H J   gYa ~WTRW[MaMaLbcd        s%A!C=A$D= D  D  DDc V^8dQhRRRR/#)rr/r0r rr )r s"r rrs  = S rcTp\^4F@pVfR#\VRR4pVeVu#VP;'g VPpKB R# \dRpL=i;i)zfThe buffered ``httpx.Request`` carried by the exception chain (SDK wrapper or httpx error), else None.Nrequest)ranger% RuntimeErrorr2r3)r/rN_rs& r _failed_requestrso$)D 1X < dIt4G  N~~11!1!1   G s A A$#A$c V^8dQhRRRR/#)rrrr z Optional[int]r )r s"r rrsrc\VRR4p\V\4'd\VP R44#\V\ \ \34'd \V4#R#)contentNzutf-8)r%r#r)r@encoder bytearray memoryview)rrs& r _request_body_bytesrsRgy$/G'37>>'*++'E9j9::7| rc(V^8dQhRRRRRRRR/#) rr/r0attemptsr]r}rr r)r )r s"r rrs/PPMPPsPWZPrc ^RIHp\V4pT!\\ VRR4;'g T;'gR44P ;'gRp\ V4pRT RT RV^8wdR MR 2pVf VR ,#VR \^\VR , 44 R 2, pV\8d VR,#VR ,#)zThe one user-facing line for "no stream event ever arrived and the connect retries are spent": names the host, the attempt count and the serialized request size so a body-size limit is distinguishable from an outage without reading agent.log.)urlparseurlNrz the endpointu❌ Could not open a stream to rz attemptrWu;; the endpoint looks unreachable — try again in a moment.z (request iz KB)zH; the endpoint or a proxy in front of it may reject requests this large.) urllib.parserrr)r%hostnamerr_roundLARGE_REQUEST_HINT_BYTES)r/rr}rrhostsizelines&$$ r connect_exhausted_noticers&e$G C5GGGGRH I R R d dVdD w 'D ,TF'(8S[_`S`CfhKi jD |SSSjQdTk 234D 99D ''``` O OOrc ,V^8dQhRRRRRRRRRR /#) rrrr/r0rr]r}r rr )r s"r rrs2**3*}*SV*be*jn*rca\WVR7o\;QJd4V3Rl\VRR4;'gR4F 'gK RM) RM%!V3Rl\VRR4;'gR44'dR#VPS4R#)zBuffer :func:`connect_exhausted_notice` once per turn: the outer retry/fallback loop re-enters the stream call several times, and every pass exhausting the same budget must not add another copy.)rr}c3D<"TFwr\V4S8HxK R#5irG)r))rH_kindrCtexts& r rI2buffer_connect_exhausted_notice..s a.` 3s8t .`s _retry_status_bufferNTFr )ranyr%r)rr/rr}rs&&$$@r buffer_connect_exhausted_noticersq $Ex PD s age=SUY.Z.`.`^`.` asss age=SUY.Z.`.`^`.` aaa ##D)r) zcf-rayzcf-cache-statuszx-openrouter-providerzx-openrouter-modelzx-openrouter-idz x-request-idz x-vercel-idviaserverzx-forwarded-fori)r'rrrrPrr-r)__doc__ __future__rloggingrtypingrrrr getLoggerrBrzr'rr-rPrmrrrrrrr__all__r rr rs# ,,   8 $  ,R*q<"D:>"DJ :> >&  P"* r