+ iHj߰ XRt^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RI H t H t ^RI H t ^RIHt^RIHt^RIHt]P(!]4t]!RR 04t]!R R 04t]]P6]]3,tR tR RdRReRRf/tRRlt RRlt!RRlt"!RR4t#RRlt$RRRRRR/RRllt%RRRRRR/R R!llt&]%t']&t(R"R#lt)RRRRR$R/R%R&llt*R'R(lt+R)R*lt,!R+R,] ],4t-]-t.R-R.R/R0R1R2/t/!R3R44t0R5R6lt1R7RR8RR9RR:RR;R/R<R=llt2R>R?lt3R7RR8RR9RR;R/R@RAllt4RBRClt5RDRElt6RFRGlt7RHRIlt8RJRKlt9R]8R ]9/t:RLRMlt;RNROltRTRUlt?RVRWlt@RXRYltARZR[ltB]@3R\R]lltCR^R_ltDR`Ra/RbRclltER#)gz?Core NeMo Relay adapters for physical Hermes provider attempts.) annotationsN)CallableIterator)partial)SimpleNamespace)Any) relay_runtimereasoning_contentreasoning_detailszx-dynamo-parent-session-idzx-dynamo-session-idg$@chat_completionscodex_responsesanthropic_messagesc V^8dQhRRRR/#)metadatadict[str, Any] | Nonereturnstr)formats"4/home/ubuntu/.hermes/hermes-agent/agent/relay_llm.py __annotate__r&s77-7#7c^\T;'g/PR4;'gR4#)api_mode)rget)rs&r _api_moder&s& B##J/552 66rc$V^8dQhRRRRRR/#)r provider_namerrrrr)rs"rrr*s(BBB8MBRUBrc\\P\V44pVe V^,#T#)zGReturn Relay's canonical operation name when Hermes knows the API mode.)_RELAY_PROTOCOL_BY_API_MODErr)rrprotocols&& r_relay_operation_namer#*s+*..y/BCH".8A;AMArc$V^8dQhRRRRRR/#)rrrrrrdict[str, Any]r)rs"rrr0s"32GNrcT\T;'g/4pVPRV4V#)zHPreserve the physical provider when the operation name is canonicalized.zhermes.provider)_jsonable_dict setdefault)rrrelay_metadatas&& r_relay_metadatar*0s)#HNN3N/? rc]tRt^7tRt]RRl4tRRltRRltRR lt R R lt ] PR R l4t RRltRRltRRltRRltRRltRRltRtR#)_ManagedAttemptzFRelay request state shared by the sync, async, and streaming adapters.c 0V^8dQhRRRRRRRRR RR R /#) r session_id str | Nonerequestr%rrnamer model_namerz_ManagedAttempt | Noner)rs"rr_ManagedAttempt.__annotate__;sF b b# b.< bH] b b"% b  brc  Vf \4pV'gR#\P!V4wrgpVeVeVP4'gR#V!WgWW4VR7#)zeReturn the managed attempt for ``session_id`` (None: the inherited turn's), or None to run unmanaged.Nr1r2)_current_session_idrresolve_execution_contextmanaged_execution_enabled) clsr.r0rr1r2runtimesessionparents &&&&$$ rresolve_ManagedAttempt.resolve:sY  ,.J#0#J#J:#V & ?goW5V5V5X5X7VhV`aarc8V^8dQhRRRRRRRRRR R R R R R R/#)rr:relay_runtime.RelayRuntimer;rr<r0r%rrr1rr2rNoner)rs"rrr3IsN2212 dkk:t/NP\^h VGMM846Fw}}^fHg  -/"//1 rc V^8dQhRRRR/#)r next_requestrrr%r)rs"rrr3^s  S ^ rc p\VPWPVPVPR7#))rCcodec_baseline_bodyr)_provider_requestr0rJrOr)rWr[s&&rprovider_request _ManagedAttempt.provider_request^s+ LL,99 $ 3 3dmm  rc$V^8dQhRRRRRR/#)rcallbackCallable[..., Any]argsrrr)rs"rrr3ds" 0 0%7 0 0 0rc laaRVV3RllpVPP4PV4#)uRun a Hermes callback in a fresh copy of the captured context. Relay can invoke callbacks while another still owns the captured Context (hence the copy); nested relay calls run unmanaged — see relay_runtime.managed_callback_guard.cV^8dQhRR/#rrrr)rs"rr2_ManagedAttempt.run_callback..__annotate__hs ' ' 'rc<\P!4;_uu_4S!S!uuRRR4# +'giR#;iNrmanaged_callback_guard)rdrbsrguarded-_ManagedAttempt.run_callback..guardedhs* 55778777s 0 A )rVcopyrun)rWrbrdrms&fj r run_callback_ManagedAttempt.run_callbackds- ' '||  "&&w//rc V^8dQhRRRR/#)rrawrrr)rs"rrr3rs))3)3)rc tWPR&\V4VPR&VPR,#valuejson)rS _jsonable)rWrts&&r_record_ManagedAttempt._recordrs5%('"$-cN&!  ((rcV^8dQhRR/#)rrzIterator[None]r)rs"rrr3xs>rc# \"RxR# \dpYPR&hRp?ii;i5i)Nerror) BaseExceptionrSrWexcs& r_recording_errors!_ManagedAttempt._recording_errorsws-   ),  g &  s, , )$),c$V^8dQhRRRRRR/#rrbrcr[rrr)rs"rrr3s"!!1!!!rc VP4;_uu_4VPWPV44pRRR4VPX4# +'giL!;i)z\Provider callback handed to Relay: run ``callback`` on Relay's (possibly rewritten) request.N)rrqr_rz)rWrbr[rts&&& rinvoke_ManagedAttempt.invokesI  # # % %##H.C.CL.QRC&||C  & %s !A A# c$V^8dQhRRRRRR/#rr)rs"rrr3s#!!+=!S!UX!rc \aa"RVV3RllpVP4;_uu_4VPV4oVPP4P \ P V!44GRjxL pRRR4VPX4#L +'giL#;i5i)cV^8dQhRR/#rgr)rs"rr2_ManagedAttempt.invoke_async..__annotate__s 5 5S 5rc<"\P!4;_uu_4S!S4GRjxL uuRRR4#L +'giR#;i5irjrk)rb final_requestsr call_provider3_ManagedAttempt.invoke_async..call_providers65577%m44874877s%A ><> A> A AN)rr_rVrorpasyncio create_taskrz)rWrbr[rrtrs&f& @r invoke_async_ManagedAttempt.invoke_asyncs 5 5 # # % % 11,?M ))+//0C0C]_UUC&||C  V& %s/#B,AB9B:B>B,B B) $B,c$V^8dQhRRRRRR/#)r relay_callrc callbacksrrr)rs"rrr3s"  &8 c c rc VPP!VPWPVP.VO5/VP B#)zGReturn the awaitable running ``relay_call`` inside the session context.)r:run_in_session_asyncr;rPrMrR)rWrrs&&*r run_managed_ManagedAttempt.run_managedsD||00 LL*nnd6H6H KT X\XiXi  rc$V^8dQhRRRRRR/#)rrrdefer_logical_completionboolrrr)rs"rrr3s" * *= *D *UX *rc JVPPR4pVe\P!W4'dVh\ V\ 4'dVfRVP9dh\ PRRR7VPV4VPR,#)zRe-raise the provider's own error, or recover a completed provider result. Must be called from the ``except`` handling ``exc`` (bare ``raise``).r~rwz]NeMo Relay LLM post-processing failed after provider success; returning the provider responseTexc_info) rSrr _is_relay_wrapped_callback_error isinstance Exceptionloggerwarning _complete)rWrrcallback_errors&&& rresolve_failure_ManagedAttempt.resolve_failures**..w7  %-*X*XY\*m*m #y))^-G7Z^ZkZkKk  k   /0  ))rc$V^8dQhRRRRRR/#)rmanagedrrrrr)rs"rrr3s!##c#T#c#rc VPV4RVP9d6\WPR,4'dVPR,#\V4#rv)rrS _json_equal _namespace)rWrrs&&&rresult_ManagedAttempt.resultsO /0 d'' 'KARARSYAZ,[,[$$W- -'""rc V^8dQhRRRR/#)rrrrrAr)rs"rrr3s??$?4?rc HV'g\VPRR7R#R#)success)outcomeN)_complete_logicalrH)rWrs&&rr_ManagedAttempt._completes' dllI >(r) rJrOrVrHrrPr<rSrRrMr0r:r;N)__name__ __module__ __qualname____firstlineno____doc__ classmethodr=rXr_rqrz contextlibcontextmanagerrrrrrrr__static_attributes__rrrr,r,7sjP b b2* 0) ! ! *# ??rr,cV^8dQhRR/#)rrr/r)rs"rrrs;;Z;rcd\P!4pVfR#VPP#)zKReturn the inherited Hermes turn's session id, or None outside a live turn.N)r active_turnleaser.)turns rr6r6s)  $ $ &D<4:TZZ%:%::rr.rrFc8V^8dQhRRRRRRRRRR R R R R RR/#rr0r%rbCallable[[dict[str, Any]], Any]r1rr2r.r/rrrrrrr)rs"rrrsN== ='F=QT=be==-B=ei= =rc n\PW@WRVR7pVf V!V4#\VPVPP P P\VPV444pTPY4# \dp TPY4uRp ? #Rp ? ii;i)zRun one non-streaming physical provider attempt through Relay. ``session_id`` defaults to the inherited Hermes turn's session (unmanaged when there is none).r5N) r,r=_run_awaitablerr:rKllmexecuterrrrr r0rbr1r2r.rrattemptrrs &&$$$$$ rrrs %%j8[e%fG  F !4!4 OO ! ! % % - -ww~~x/P"   >>' << F&&sEEFsAB B4B/)B4/B4c8V^8dQhRRRRRRRRRR R R R R RR/#rr)rs"rrrsN = =  ='F =QT =be = =-B =ei =  =rc"\PW@WRVR7pVfV!V4GRjxL #VPVPPP P \VPV44GRjxL pTPY4#LlL \dp TPY4uRp ? #Rp ? ii;i5i)zAsync ``execute``.r5N) r,r=rr:rKrrrrrrrrs &&$$$$$ r execute_asyncrs %%j8[e%fGg&&&F++GOO,A,A,E,E,M,MwW^WkWkmuOvww >>' << 'w F&&sEEFsQ(CBCABBBCB C&B<6C7C<CCcV^8dQhRR/#)rrrr)rs"rrrsrc\P!\4;_uu_4\P!4RJuuRRR4# +'giR#;i)NF)rsuppress RuntimeErrorrget_running_looprrr_has_running_event_looprs6   \ * *'')5 + * * * s A A completed_response_predicatec<V^8dQhRRRRRRRRRR R R R R RRRR/ #)rr0r%stream_factoryrr1rr2 finalizerCallable[[], Any]rrrrrCallable[[Any], bool] | Nonerrr)rs"rrrs\%% %-L%WZ%hk% %,A%#%Kg% %rc \4pVe\4'd V!V4#\WWVWEVVR7 p VeV P4V Pe0V P R4V P RR7V P#V #)uPRun a provider stream under the inherited Hermes turn when present. With ``completed_response_predicate`` set, a factory that ignores ``stream=True`` and returns a complete response is unwrapped and returned directly (pre-Relay behavior). Detecting that primes the lazy pipeline: a genuine first chunk is buffered, but provider latency and pre-first-yield errors may surface before this returns. AnthropicAuxiliaryClient and other shims that ignore ``stream=True``), unwrap and return the completed response directly. This mirrors the pre-Relay behavior where ``call_llm(stream=True)`` returned the raw response and the consumer's own ``hasattr(stream, "choices")`` check handled it (#11732, #55933) — without the unwrap the response stays trapped as ``final_response`` on the inner ManagedLlmStream and the outer consumer sees an empty stream. )r.r1r2rrrrr cancelledlogical_outcome)r6rstream_prime_completed_responsefinal_response_finish_logical_close) r0rr1r2rrrrr.rs &&$$$$$$ rstream_currentrs"%&J466g&&JjIa%AG $/))+)  *{3%%% Nrc$V^8dQhRRRRRR/#)rloopzasyncio.AbstractEventLooprrrrr)rs"rrr s"3STrcaaa\VRR4o\S4'gR#RV3Rllo\P!VV3RlR\RR 7R# \ d\ PR \4R #i;i) aAwait ``stream.aclose()`` on ``loop`` when the stream exposes one, bounded by ``_ACLOSE_TIMEOUT``. Returns False when the attempt is abandoned: the daemon thread still owns the running loop, so the caller must leave it open rather than ``loop.close()`` under it.acloseNTcV^8dQhRR/#rrrAr)rs"rr%_aclose_on_loop..__annotate__src2<"S!4GRjxL R#L5irjr)closesr close_stream%_aclose_on_loop..close_streamsg s c0<SPS!44#rj)run_until_complete)rrsr!_aclose_on_loop..sD++LN;rzrelay-llm-stream-aclosez@Relay stream aclose did not finish; abandoning the close attempt)r1timeouttimeout_messagezSRelay stream aclose exceeded %ss; abandoning the close attempt and its private loopF)getattrcallabler_run_on_daemon_thread_ACLOSE_TIMEOUT TimeoutErrorrr)rrrrsf&@@r_aclose_on_loopr st FHd +E E?? ++ ;*O^    a   s#A%A<;A<c$V^8dQhRRRRRR/#)rrbrc raw_iteratorrrztuple[Any, bool]r)rs"rrr$s##5SM]rcHV!\V4R3# \dRu#i;i)zSRead one synchronous provider chunk without leaking StopIteration through a Future.FNT)next StopIteration)rbrs&&r_next_provider_chunkr$s.l+U22 s  !!cz]tRtRt$RtRtR]R&R;t;t;t t Rt R]R&R;t t RtR ]R &R;ttRtR ]R &RtR ]R&RRRRRRRRRRRRRR/RRlltRRltRRltRRltRRltR R!ltR"R#ltR$R%ltR:R&R'lltR(R)ltR*R+ltR,R-ltR.R/ltR0R1lt R2R/R3R4llt!R5R6lt"R7R8lt#R9t$R#);ManagedLlmStreami,zUSynchronous view of one Relay-managed provider stream, driven from the worker thread.NrrFz asyncio.AbstractEventLoop | None_loop(relay_runtime.RelayOperationLease | None_runtime_lease_LogicalCall | None_logicalr/_logical_response_model_nameon_stream_createdon_chunk chunk_adapter accept_chunkrrrcPV^8dQhRRRRRRRRRRR R R R R R RRRRRRRRRRRR/#)rr0r%rrr.rr1r2rrrzCallable[[Any], None] | NonerrzCallable[[Any], Any] | NonerrrrrrrrrAr)rs"rrManagedLlmStream.__annotate__8s%%%%7V%gj%%"%/@%8%Kg%3 %Jf % 'C % ( % KO % %rc  Wn\T ;'g/PR4;'gR4PR4pV'dWT3MRwVnVnY;'g\ V uVnVnVn W'VuVn Vn Vn Wn .Vn.Vn\ P#W1WVR7pVfVP%V4R#VP&VnVP+V4R#) call_rolerz auxiliary:Nr5)NN)_defer_logical_completionrr startswith_logical_model_name_logical_provider_namer _on_chunk_chunk_adapter _accept_chunk_stream_factory_on_stream_created _finalizer_completed_response_predicate _raw_chunks_prefetched_chunksr,r=_start_unmanagedrHr _start_managed)rWr0rr.r1r2rrrrrrrr auxiliaryrs&&&$$$$$$$$$$$ rrXManagedLlmStream.__init__8s*B&R,,[9??R@KKLY V_@Req= $"=BJLgLg]giu?+T-?IWluFd5t-I*24-/!))*x_i)j ?  ! !' *   G$rc V^8dQhRRRR/#)rr0r%rrAr)rs"rrrPs ( ( (4 (rc VPV4pVPpVe'V!V4'dW n\R4VnR#W nVP eVP V4\V4VnR#Nr)rr riter_stream_raw_stream_resourcer)rWr0 raw_stream predicates&& rr#!ManagedLlmStream._start_unmanagedPsm))'2 66  Yz%:%:", 8DL $.!  " " .  # #J /J' rc V^8dQhRRRR/#)rrr,r[rr)rs"rrr\s%%o%S%rc "VPpRpV!VPVPV44pVPpVeHV!WT4'd:W@nRVn\ VRR4p\V4'd V!V4R#R#VPeV!VPV4V!\V4p\P!\W84GRjxL wrV 'dMVVPeV!VPV 4'gM.\!V 4p VP"P%W34V 5xKRVn\ TRR4p\T4'd T!T4R#R# \d pYpn hRp?ii;iL \d pYpnhRp?ii;i \d pYpn hRp?ii;i \ TRR4p\T4'd%T!T4i \d pYpn hRp?ii;ii;i5i)zIRelay's provider callback: run the factory and yield JSON-encoded chunks.NTr)rqrr_r r_provider_completedrrr _close_errorrr*r to_threadrrryr!append_callback_error) rWrr[rqr-r.rrrchunk exhausted encoded_chunks &&& r_provider_stream!ManagedLlmStream._provider_stream\s++  ! %d&:&:G?##'+D $ J6E '%(+%#$m #&  %(+% J6E '$(+%sHA F H?E1H A F F 5F 6F H%F'-H1 F<FFH F F$FF$$G' F>2F99F>>HH!G*)H* H5G<<HHHc V^8dQhRRRR/#)rrr,rrr)rs"rrrsCrc VPeR#VPpVfVPVP4pVPe\ V4Vn\V4# \d pY0nhRp?ii;irj) r6rrqrr_response_model_namer ryr)rWrresponsers&& r_relay_finalizer!ManagedLlmStream._relay_finalizersz    + **H"//@''34H4R1X& & #&  sAA&& A=1A88A=c V^8dQhRRRR/#)rrr,rrAr)rs"rrrso$rc  (aaRVV3RllpSPP4Sn\P!4;SnpVP SPSPPPP\SPS4V\SPS444SnR# \dpSP e.SP!T4'dSP#4Rp?R#SP eASP%\'T4'dRMRTR7SP P)4RSnSP+4h RSnSP+4i;iRp?ii;i)zCOpen Relay's stream on a private event loop owned by this iterator.c V^8dQhRRRR/#)rr7rrrAr)rs"rr5ManagedLlmStream._start_managed..__annotate__s G G G Grcr<SPe(SPSP\V44R#R#rj)rrqry)r7rrWs&r observe_chunk6ManagedLlmStream._start_managed..observe_chunks+~~)$$T^^Yu5EF*rNrfailedr~)r:acquire_operation_leaser rnew_event_looprrrrKrstream_executerr:r@r+r_recoverable_relay_failure!_preserve_pending_provider_chunksr_is_cancellationr_release_runtime_lease)rWrrGrrsff rr$ManagedLlmStream._start_managedsC G G&ooEEG  ' 6 6 8 8DJ22##OO))--<e!74+@+@'#JDL  zz%$*I*I#*N*N668 .::)((8H8M8MS[cf(gJJ$$&! ++- " ++- s7BC F$F 3F  AE0F 0F  F  FcV^8dQhRR/#)rrrr)rs"rrrs*rc V#rjrrWs&r__iter__ManagedLlmStream.__iter__s rcV^8dQhRR/#rr)rs"rrrs;;4;rc VP'gfVP'gR\P!\4;_uu_4VPP \ V44RRR4R#R#R# +'giR#;i)z4Advance once while preserving a genuine first chunk.N)_closedr"rrrr5rrUs&rr*ManagedLlmStream._prime_completed_responsesX|||D$;$;$;$$]33''..tDz:43%<|333s %A:: B c V^8dQhRRRR/#)rrrrrr)rs"rrrsmrc \V\4;'d#VP;'dVPRJpV'd,VP'd\ P RRR7R#V'd\ P RRR7V#)a>Relay post-processing failed after the provider already succeeded. Not recoverable once Relay delivered output with no provider-source match: that chunk's source stays in ``_raw_chunks``, so a raw replay would emit already-represented content a second time (and unredacted, if the Relay transformation was the point).NztNeMo Relay stream post-processing failed after transformed output; propagating rather than replaying provider chunksTrFz_NeMo Relay stream post-processing failed after provider success; preserving the provider result)rrr2r6_delivered_unmatchedrr)rWr recoverables&& rrN+ManagedLlmStream._recoverable_relay_failures!i0nnT5M5MnnRVRfRfjnRn 4444 NND     NNq  rc$V^8dQhRRRRRR/#)rrrr~BaseException | NonerrAr)rs"rrrs#s3GSWrc  VP'dR#RpVe`VPeR^RIHpVP V4'dRpM1TP Y P ;'gRVPR7p\VPWPVP VPVPVR7RVnR#)zComplete the logical LLM scope unless the caller deferred it. An auxiliary stream that ended in ``error`` reports it like a deferred auxiliary call does.N)auxiliary_call_outcomerr)providermodel)rr2rresponse_model_nameoperation_lease error_class) rragentrdis_cancellationrirrr r r )rWrr~rirds&&& rr ManagedLlmStream._finish_logicals  ) ) )   !9!9!E 4%55e<<%4@@$?$?$E$E2TMeMeAg  MM77O7O554KlKl //[  rcV^8dQhRR/#rgr)rs"rrrs)*)*#)*rc aSP'd\hSP'dSPP4#SPf\\ SP S4pVSJg&SPe0SPV4'gSPRR7\hV#RV3RllpSPPV!44p\+SP4FAwpwrg\-Y4'gKT^8dRSn SPRT^,1Tu# RSn RSnSP1T4# \dESP'dRSn SPR4SPRR7\Rh\dpSPpTe2\ P"!Y44'dSPRTR7ThSP%T4'd!SP'4\ S4uRp?#SP\)T4'dRMRTR7hRp?ii;i) NrrcV^8dQhRR/#rgr)rs"rr/ManagedLlmStream.__next__..__annotate__s - -# -rcJ<"\SP4GRjxL #L5irj)anextr+rUsr next_chunk-ManagedLlmStream.__next__..next_chunkst||,, ,,s #!#TrrI)rr~)rZrr"poprrr+rrrStopAsyncIterationr!output_modifiedrrr6rrrNrOrP enumeraterr^r)rWr7rsrrindexencodedrtsf r__next__ManagedLlmStream.__next__s <<<   " " "**..0 0 :: t,E}!3!3!?HZHZ[`HaHa K 8##L - - JJ11*,?E"&/t/?/?%@ !E>G5**19+/D($$[uqy[1 &A $$(!""5))1" *'+$   + KK K 4T ) !11N)m.\.\]`.q.q HN K$$..s33668Dz! KK7G7L7L RZbeK f  s79 EI/9I)I*AI I I"'I  IcV^8dQhRR/#rr)rs"rrrstrc \VPRR7VPRuqnVeVhR#)zAClose an explicitly abandoned stream and cancel its logical call.rrN)rr3)rW close_errors& rrManagedLlmStream.closes4 K 0)-):):D& &  "  #rcV^8dQhRR/#rr)rs"rrrs**4*rc VPUUu.uFwrVNK pppVPP4VPVPrTR\ V4RR3wVnVnVnVnVe%\WE4pV'dVP4VPR4VP4R#uuppi \d\PRRR7RpLgi;i TP4i;i)z@Switch a failed Relay stream to its undelivered provider chunks.Nz4Relay stream cleanup failed during provider fallbackTrr)r!clearrr+r*r,rrrrdebugrrrQ)rW_encodedrtpendingr relay_stream completeds& rrO2ManagedLlmStream._preserve_pending_provider_chunkss,0,<,<=,<=83,<=  !ZZlRVX\]dXegkmqRqO DL$";T=O *% / CIJJL   +  ' ' )>!%LL!WbfLg $I%  ' ' )s; C:C5? C C5!C5 $C2/C51C22C55Dc V^8dQhRRRR/#)rrrrrAr)rs"rrr(s$$=$T$rc 2VPf WnR#R#rj)r3rs&&r_keep_first_close_error(ManagedLlmStream._keep_first_close_error(s    $ #  %rcV^8dQhRR/#rr)rs"rrr,s N N4 Nrc VPVP3Uu/uFqfK\V4VbK ppRVnRVnVP4F+p\ VRR4p\ V4'd V!4K+K- R#uupi \ d4pTPT4\PRRR7Rp?KoRp?ii;i)zUClose the unmanaged provider stream/resource once each (they may be the same object).NrzProvider stream cleanup failedTr) r+r,idvaluesrrrrrr)rWr resourcesresourcerrs& r_close_provider_resources*ManagedLlmStream._close_provider_resources,s(, d6O6O'Pb'P!XRUAX'P b $(!!((*HHgt4E NE??G#+c N,,S1 = MM Ns"BB&B  C (CC r~c$V^8dQhRRRRRR/#)rrrr~rbrrAr)rs"rrr:s#***5I*UY*rc VP'dR#RVnVPP4VPRuq0nVRJpVfVP 4M\ W0P 4pVPW4V'dVP4VP4R# \dpTPT4Rp?L\Rp?ii;i TP4i;ir) rZr"rrrrr+rrrrrQ)rWrr~r close_looprs&$$ rrManagedLlmStream._close:s <<<   %%' *#zz4 D*T)J|..06!0||!DJ   8  ' ' ) !600556  ' ' )s5,C$B49)C4 C?CCCCC/cV^8dQhRR/#rr)rs"rrrOsrc XVPRuqnVeVP4R#R#rj)r release)rWrs& rrQ'ManagedLlmStream._release_runtime_leaseOs)%)%8%8$""   MMO rcV^8dQhRR/#rr)rs"rrrTs111rc *VPRR7R#)rrN)rrUs&r__del__ManagedLlmStream.__del__Ts K 0r)rr6rr3rZr rr^rr rrr rrrr"r2r!r,r r+rrrwrj)%rrrrrr__annotations__rwrZr2r^rr+r,r r3r6r r rXr#r:r@r$rVrrNrr{rrOrrrrQrrrrrrr,s_NCMRRORgR 36J.2E +2%))G"?CN<C%))L?$(H!(/3 *3%;?%jn%6: %im % FJ % +/ % RW %0 (%N :; ,()*V*&$ N*D** 11rr text_deltatextthinking_deltathinkingsignature_delta signaturec]tRtRtRtRRltRRltRRltR R ltR R lt R Rlt R]R]R] R] /t RRlt RRRllt RtR#)AnthropicStreamAccumulatori^z !rc V^8dQhRRRR/#rr)rs"rrrvs H H~ H$ Hrc VPR4VPR4r2\V\4'd\V\4'gR#VPP V/4pVPR4p\ PV4pVeR\VPV4;'gR4\VPV4;'gR4,WF&R#VR8XdJ\VPRR44\VPR4;'gR4,VR&R#VR8Xd4R V9d+VP R .4PVR ,4R#R#R#) rydeltaNrrinput_json_delta _partial_json partial_jsoncitations_deltacitation citations) rrrrrr(_ANTHROPIC_APPEND_DELTASrrur5)rWrryrr delta_typefields&& r_on_content_block_delta2AnthropicStreamAccumulator._on_content_block_deltavs#{{7+W[[-Au%%%Zt-D-D  ''r2YYv& (,,Z8  uyy/5526UYYu=M=S=SQS9TTEL - -%(?B)G%H3uyyYgOhOnOnlnKo%oE/ " , ,u1D   [" - 4 4U:5F G2E ,rc V^8dQhRRRR/#rr)rs"rrrs + + +D +rc VPR4p\V\4'd;VPP RUu/uFq3V9gK W2V,bK up4RV9dVR,VPPR4rT\V\4'dE\V\4'd//VCVP 4UUu/uF wr6VfK W6bK uppCpW@PR&R#R#uupiuuppi)rrN) stop_reason stop_sequence stop_details)rrrrritems)rWrrrr current_usagevs&& r_on_message_delta,AnthropicStreamAccumulator._on_message_deltas G$ eT " " MM 7g!v7g!puku+!1X+7g!v w g #*7#3T]]5F5Fw5O=-..:eT3J3J_=^ekkm,]mdaqTQTm,]^%*MM' " "w -^sC8 C8C=C= message_startcontent_block_startcontent_block_delta message_deltacV^8dQhRR/#)rrr%r)rs"rrrs44.4rc \VP4Uu.uFp\VPV,4NK! ppVFepVPRR4pVfK\P !\ \4;_uu_4\P!V4pRRR4WCR&Kg /VPCRV/C#uupi +'giL/;i)rNinputcontent) sortedrrrurr TypeError ValueErrorrxloadsr)rWryblocksrrs& rfinalize#AnthropicStreamAccumulator.finalizes9? 9MN9M$t||E*+9MNEii6G"((J??"jj1G@!(g  4$--3F33O@?s%B<C C Nc V^8dQhRRRR/#)rbaserrr)rs"rrrs""S"C"rc VP4pVPR.4p/\V4CVCpV'gRV9dW4R&\V4#)z8Return the attribute-shaped response consumed by Hermes.r)rrur'r)rWr assembledrmergeds&& rr?#AnthropicStreamAccumulator.responsesNMMO -- 2.6N4(6I6 iv- '9 &!!r)rrrj)rrrrrrXrrrrrrrr?rrrrrr^sTF5't . H + *,ACZ6IZO 4""rrc ,V^8dQhRRRRRRRRRR /#) rr:r@r;rr<rrrr r)rs"rrrs4$$ '$25$?B$Nc$$rc\P!VP4p\T;'g/P R4;'gR4pVe#V'dVP P VJdR#VP;_uu_4VP'd RRR4R#VP;_uu_4VPP V4pVf\T;'g/P R4;'gR4pVPWPPP\PVPP P"V/\P$!VP&3/RV/BR7;qdPV&RRR4RRR4VXV3# +'giL;i +'giL(;i)zTReturn (turn, handle, request_id) for the turn's logical LLM scope, pushing it once.api_request_idrNrprimaryzhermes.call_role)rDrr)rrr.rrrhost finalize_lockclosedlogical_llm_locklogical_llm_callsrun_in_sessionrKscopepushLOGICAL_LLM_SCOPE ScopeTypeFunctionruntime_metadata runtime_id)r:r;r<rr request_idrDrs&&&& rrGrGsf  $ $W%7%7 8Dhnn"))*:;AArBJ |:)G    ;;;   " " "++// ;F~R 4 4[ A N NYO >E>T>T]]0055}7V7VMM++44V2*;;G-I +I= H  I"H?3I>H??I I I I& c V^8dQhRRRR/#)rr~rrrr)rs"rrrs\\M\d\rcL\V\P\\34#rj)rrCancelledErrorInterruptedErrorKeyboardInterruptrJs&rrPrPs eg446FHYZ [[rc4V^8dQhRRRRRRRRRRRRR R /#) rrrrr2r/rrgrirrAr)rs"rrrsH   %( 6@  ;E    rc \P!4pVe V'gR#VP;_uu_4VPP V4pRRR4Xe\ WgV3WW4VR7R#R# +'giL);i)zComplete the active turn's logical LLM call after caller validation. ``error_class`` (a classifier reason) rides on a call that reports its route: the error that ended a failed call, or the last one a successful call recovered from.N)rr2rrgri)rrrrrr)rrr2rrgrirrDs&$$$$$ rcomplete_logical_callrso  $ $ &D |>   ''++N;   > *G'^i   s A55 B c V^8dQhRRRR/#)rr?rrr/r)rs"rrr sGG3G:Grc\V\4'dVPR4M \VRR4p\V\4'dVP 4'dV#R#)zr> sJ%/$%?%?HLL !WXW^`dEeEuc**u{{}}5F$Frc 0V^8dQhRRRRRRRRRRR R/#) roriginalr%r0rrCr]rrrr)rs"rrrs>'*CQ.:Orc\VRV4p\V\4'gTp\V4pVe\WR4'gTp\ WT4pVP 4VP 4,FMp W9dVP V R4KW9g!\W,Wy,4'dKCW,Wi&KO \WWxR7\VRR4p \V \4'dHV P4U U u/uF+wr\V 4P4\9gK)WbK- p p p \P\V44RJ;'gRV9p V 'dLV 'gDV P4U U u/uF'wr\V 4P4R8wgK%WbK) p p p V 'd,/\VPR4;'g/4CV CVR&V#uup p iuup p i)rN)baseline interceptedheaders extra_headers traceparent)rrrr_provider_request_bodykeysru$_restore_provider_message_extensionsrrlower _RELAY_INTERNAL_PROVIDER_HEADERSr!rr)r r0rCr]rrfinalr"r#keyr$rrsupports_extra_headerss&&$$$ rr^r^sgy'2G gt $ $$ NE&{7/W/W&,W? ==?[%5%5%777C% #t$$K 8H(-,X,X(- 8 -Xxigy$/G'4  $+MMOnODAs1v||~Mm7m414On9<.?s!f 3KK !8KKrc pRRRVP4UUu/uFwrVR8wgKWbK upp/#uuppir;)r)r5rrs& rrr?@s46:zQWWY3^YTQRSW]R]DADY3^_3^s 2 2 )rrur6rJs&r_codex_codec_toolsrB9s2 xx  $ K_rc V^8dQhRRRR/#r8r)rs"rrrDsmmNmtmrc$\VRR4R#)c&RV9;'dRV9#)r<rrr>s&rr#_chat_codec_tools..Es:?#F#FvQ#FrcRR/VC#r;rr>s&rrrFEsSY[eRkijRkrN)r6rAs&r_chat_codec_toolsrHDs4FHklrc$V^8dQhRRRRRR/#)rr0r%rrrr)rs"rrrLs#;PUcrc\V4pVPRR4\P\ V44pVe V!V4V#)rN)r'ru_CODEC_TOOL_NORMALIZERSrr)r0rrJ normalizes&& rrIrILsA ' "DHHY'++Ih,?@I$ Krc ,V^8dQhRRRRRRRRRR/#)rr r%r,r"r#rrAr)rs"rrrVs4;;;%3;BP;_m; ;rca \;QJd.RWW#34FNK 5M!RWW#344p\;QJdRV4F 'dK RM RM !RV44'd*\VUu0uFp\V4kK up4^8wdR#\VRR/Fp\;QJdRV4F 'dK RM RM !RV44'gK?Vwrxr\F^o S V9gK \ ;QJd!V 3RlWV34F 'gK RM RM!V 3RlWV344'dKRVS ,VS &K` K R#uupi) zGRestore provider wire fields that Relay's typed codec cannot represent.c3B"TFqPR4xK R#5i)messagesNr=).0rJs& r 7_restore_provider_message_extensions..Zsd;c4((:..;cc3B"TFp\V\4xK R#5irj)rr4)rQms& rrRrS[s:Mqz!T""MrTFTNstrictc3B"TFp\V\4xK R#5irj)rr)rQrs& rrRrS^sEH:gt,,HrTc3.<"TF pSV9xK R#5irjr)rQrVr-s& rrRrSbs3"XQq"Xs)tuplealllenzip _PROVIDER_MESSAGE_EXTENSION_KEYSany) r r,r"r# message_listsrVrPoriginal_message final_messagebaseline_messageintercepted_messager-s &&$$ @rr)r)VsEdHX;cdEEdHX;cddM 3:M:333:M: : :cS`BaS`a3q6S`Ba>bfg>g4t4sEHEsssEHEEE QYN)93C&&ss3#3-"X3sss3#3-"X300&6c%: c" 4 5Cbs5Ec ,V^8dQhRRRRRRRRRR/#) rrKrrMrCr%rrrr)rs"rrrhs4 ";IUjrcV\W4pVf \W#4#VPVPV4V4p\ VRV4p\T\4'd \Yc4#\ PR4R# \ d\ PRRR7R#i;i)zCReturn the codec-only request shape used to identify real rewrites.NrzCNeMo Relay request codec baseline failed; ignoring request rewritesTrzTNeMo Relay request codec returned an unsupported baseline; ignoring request rewrites) rQr'encodedecoderrrrrr)rKrMrCrrErzrs&&$$ rrNrNhs 5 #E }%&8CC,,u||M:MJ'9g6'4  %g88 NNij  \gkls.B"B('B(c$V^8dQhRRRRRR/#)rrr%rrrr)rs"rrr{s#N>SXfrcZ\V4p\V4R8Xd\VRR4V#)r cxVPR4R8H;'d \VPR4\4#r;)rrrr>s&rr(_provider_request_body..s-AEE&MZ7__JquuZGXZ^<__rc.RR/\VR,4C#r;)rr>s&rrrlsvzAT!J--@Ar)rrr6)rrrJs&& rr'r'{s1 =D// _ A  Krc$V^8dQhRRRRRR/#)rrKrrrrr)rs"rrrs"00#0!6030rc\P\V44pVe \\VRR4V^,R4MRp\ V4'dV!4#R#)Ncodecs)r!rrrr)rKrr"rEs&& rrQrQsO*..y/BCHJRJ^GGE8T2HQK FdhEuoo57/4/rc V^8dQhRRRR/#rrwrrr)rs"rrrs??S?S?rcVe'\V\\\\34'dV#\V\ 4'd8VP 4UUu/uFwr\V4\V4bK upp#\V\\\34'dVUu.uFp\V4NK up#\\V4RR4p\V4'd\VPRRR74#\#V4P 4UUu/uF3wr\V4P%R4'dK'\V4VbK5 pppT'd \T4#\T4#uuppiuupi \d\TP44u#i;i \ dLi;iuuppi \\&3d\T4u#i;i)N model_dumprxF)modewarnings_)rrrfloatrrrryr4rZsetrrrrtrrvarsrAttributeError)rwr-itemrt attributess& rryrys } 53UD*ABB %;@;;=I=icC)D/)=II%$s+,,,12ED $E22elD9J   5 !1!1v!1!NOO 6:5k6G6G6Ij6IQTUXQYQdQdehQinc#hn6I j%/9Z >CJ>%J2 5 !1!1!344 5   k ~ &5zs` E2E8E=<F>$F8F8F>=$F$!F'#F$$F'' F54F58F>>GGc V^8dQhRRRR/#)rrwrrr%r)rs"rrrs88#8.8rcL\V4p\V\4'dV#/#)zR``_jsonable`` for values that must be a JSON object; anything else becomes ``{}``.)ryrr)rwrs& rr'r's#G $//77R7rc V^8dQhRRRR/#rrr)rs"rrrsccrc *\V\4'dA\R/VP4UUu/uFwr\ V4\ V4bK uppB#\V\ 4'dVUu.uFp\ V4NK up#V#uuppiuupir))rrrrrrr4)rwr-r|s& rrrsw%]ekkm!\m#c(Jt,<">> z "s .. loop_errorzBSynchronous Relay LLM execution cannot run on an event-loop threadc$V^8dQhRRRRRR/#)rrwrrrrr)rs"rrrs$ "rc\P!V4'gV#\4'd \V4h\P !V4#rj)inspect isawaitablerrrrp)rwrs&$rrrs=   u % %   :&& ;;u r)zopenai.chat_completionsOpenAIChatCodec)zopenai.responsesOpenAIResponsesCodec)zanthropic.messagesAnthropicMessagesCodec)Fr __future__rrrrTrrxloggingcollections.abcrr functoolsrtypesrtypingrrjr getLoggerrr frozensetr^r+rZRelayTurnContextr _LogicalCallrr!rr#r*r,r6rrexecute_currentexecute_current_asyncrrrrrrrrrGrrPrr>r^r6rBrHrKrIr)rNr'rQryr'rrrrrrrrsVE" .!   8 $$-.ACV-W#X #,.JLa-b#c ]33S#=>  FCJ7B u?u?p; =!=EI=lq=$ =! =EI =lq = % %DH%&+%jn%P6i1x}i1X )&2BJPacnoH"H"V$.07LP07nr07&*07hl07#07f\ CG $ HL # (G B_m -.@BTVgh;$&0 ?28 @IL%ir