=i`SrSSKJr SSKrSSKJrJrJrJrJ r J r J r SSK J r SSKJrJrJrJr SSKJr SSKJr SS KJrJr SS KJr SS KJrJr SS KJ r SS K!J"r"J#r# SSK$J%r% SSK&J'r'J(r(J)r) SSK*J+r+J,r,J-r-J.r.J/r/J0r0J1r1J2r2J3r3J4r4 SSK5J6r6J7r7J8r8J9r9J:r:J;r;Jr> SSK?J@r@ \(a0SSKAJBrBJCrCJDrD SSKEJFrF SSKGJHrH SSKJIrI SSKJJKrK SSK!JLrL SSK*JMrMJNrN SrOS0SjrPS1SjrQS2SjrRS3S4SjjrSS5SjrTS6S jrUS7S!jrVS8S"jrWS9S#jrXS:S$jrYS3SS%SSSSSSSS&SSS'. S;S(jjjrZSS+jr]S?S,jr^S@S-jr_SAS.jr`S//rag)Bz:Agent factory for creating agents with middleware support.) annotationsN) TYPE_CHECKING AnnotatedAnycastget_args get_originget_type_hints) BaseChatModel) AIMessage AnyMessage SystemMessage ToolMessage)BaseTool)RunnableCallable)ENDSTART) StateGraph)ToolCallWithContextToolNode)Runtime)CommandSend)ContextT) NotRequiredRequired TypedDict) AgentMiddleware AgentStateJumpTo ModelRequest ModelResponseOmitFromSchema ResponseT StateT_co_InputAgentState_OutputAgentState) AutoStrategyMultipleStructuredOutputsErrorOutputToolBindingProviderStrategyProviderStrategyBindingResponseFormatStructuredOutputErrorStructuredOutputValidationError ToolStrategy)init_chat_model) AwaitableCallableSequence)Runnable) BaseCache)CompiledStateGraph) BaseStore) Checkpointer)ToolCallRequestToolCallWrapperz)Error: {error} Please fix your mistakes.cF[U[5(a [U/SS9$U$)z3Normalize middleware return value to ModelResponse.Nresultstructured_response) isinstancer r")r>s h/home/dmtnaga/Documents/work/airagagent/rag_env/lib/python3.13/site-packages/langchain/agents/factory.py_normalize_to_model_responserBCs#&)$$VH$GG Mc^^U(dg[U5S:XaUSmSU4SjjnU$S SjnUSm[USS5H nU"UT5mM SU4SjjnU$) aCompose multiple wrap_model_call handlers into single middleware stack. Composes handlers so first in list becomes outermost layer. Each handler receives a handler callback to execute inner layers. Args: handlers: List of handlers. First handler wraps all others. Returns: Composed handler, or `None` if handlers empty. Example: ```python # handlers=[auth, retry] means: auth wraps retry # Flow: auth calls retry, retry calls base handler def auth(req, state, runtime, handler): try: return handler(req) except UnauthorizedError: refresh_token() return handler(req) def retry(req, state, runtime, handler): for attempt in range(3): try: return handler(req) except Exception: if attempt == 2: raise handler = _chain_model_call_handlers([auth, retry]) ``` Nrc*>T"X5n[U5$NrBrequesthandlerr>single_handlers rAnormalized_single5_chain_model_call_handlers..normalized_singles$G5F/7 7rCc(^^SUU4SjjnU$)z-Compose two handlers where outer wraps inner.c>>^SUU4SjjnT"X5n[U5$)Nc,>T"UT5n[U5$rGrHreq inner_resultrKinners rA inner_handlerX_chain_model_call_handlers..compose_two..composed..inner_handlers$S'2 3LAArCrSr!returnr"rHrJrKrV outer_resultrUouters ` rAcomposedA_chain_model_call_handlers..compose_two..composeds&  B B !8L/ = =rCrJr!rKz'Callable[[ModelRequest], ModelResponse]rYr"r\rUr]s`` rA compose_two/_chain_model_call_handlers..compose_twos. >! >< > > >rCc*>T"X5n[U5$rGrHrJrK final_resultr>s rAfinal_normalized4_chain_model_call_handlers..final_normalizeds g/ +L99rCr_)r\\Callable[[ModelRequest, Callable[[ModelRequest], ModelResponse]], ModelResponse | AIMessage]rUrjrYzPCallable[[ModelRequest, Callable[[ModelRequest], ModelResponse]], ModelResponse]lenreversedhandlersrMrbrKrhr>rLs @@rA_chain_model_call_handlersrpJsb  8}!! 8! 8< 8 8!     >b\FHSbM*Wf-+::8: : rCc^^U(dg[U5S:XaUSmSU4SjjnU$S SjnUSm[USS5H nU"UT5mM SU4SjjnU$) zCompose multiple async `wrap_model_call` handlers into single middleware stack. Args: handlers: List of async handlers. First handler wraps all others. Returns: Composed async handler, or `None` if handlers empty. NrErcF># T"X5IShvN n[U5$N7frGrHrIs rArM;_chain_async_model_call_handlers..normalized_singles%*';;F/7 7< !!c(^^SUU4SjjnU$)z3Compose two async handlers where outer wraps inner.cZ>^# SUU4SjjnT"X5IShvN n[U5$N7f)NcH># T"UT5IShvN n[U5$N7frGrHrRs rArV^_chain_async_model_call_handlers..compose_two..composed..inner_handlers%%*3%88 3LAA 9s " "rXrHrZs ` rAr]G_chain_async_model_call_handlers..compose_two..composeds1  B B "'w!>>L/ = =?s +)+rJr!rKz2Callable[[ModelRequest], Awaitable[ModelResponse]]rYr"r`ras`` rArb5_chain_async_model_call_handlers..compose_twos. >! >G > > >rCrdcF># T"X5IShvN n[U5$N7frGrHrfs rArh:_chain_async_model_call_handlers..final_normalizeds% $G55 +L996rtrz)r\rCallable[[ModelRequest, Callable[[ModelRequest], Awaitable[ModelResponse]]], Awaitable[ModelResponse | AIMessage]]rUr~rYzfCallable[[ModelRequest, Callable[[ModelRequest], Awaitable[ModelResponse]]], Awaitable[ModelResponse]]rkrns @@rA _chain_async_model_call_handlersrs,  8}!! 8! 8G 8 8!     >b\FHSbM*Wf-+::C: : rCc0nUHyn[USS9nUR5HXupgSnU(a=[U5n U H,n [U [5(dM[ X5SLdM*Sn O U(aMTXsU'MZ M{ [ X5$)aResolve schema by merging schemas and optionally respecting `OmitFromSchema` annotations. Args: schemas: List of schema types to merge schema_name: Name for the generated `TypedDict` omit_flag: If specified, omit fields with this flag set (`'input'` or `'output'`) T)include_extrasF)r items_extract_metadatar@r#getattrr) schemas schema_name omit_flagall_annotationsschemahints field_name field_type should_omitmetadatametas rA_resolve_schemarsOvd;&+kkm "JK,Z8$D!$77GD# UH oT;v M g7frGr`).0partrs rA ._supports_provider_strategy..qsc.bdz!.bs)zgpt-5zgpt-4.1zgpt-osszo3-prozo3-miniF)r@strr rlowerany)modelrs @rA_supports_provider_strategyr`ss"J% E= ) )UL$7  *""$$ d c.bc c rCcR^[U[5(dgURnUSLagUSLaS[R [ T5S94$[U[ 5(aSU4$[U[ 5(aE[U[5(a0[TU5(aS[R [ T5S94$g[U[5(a9[U4SjU55(aS[R [ T5S94$g[U5(a SU"T54$g)zMHandle structured output error. Returns `(should_retry, retry_tool_message)`.)FFT)errorc3<># UHn[TU5v M g7frG)r@)rexc_type exceptions rAr2_handle_structured_output_error..sM}8z)X..}s) r@r0 handle_errors STRUCTURED_OUTPUT_ERROR_TEMPLATEformatrtype issubclass Exceptiontuplercallable)rresponse_formatrs` rA_handle_structured_output_errorrws  o| 4 4#11M5<<3y><RRR-%%]""-&&:mY+O+O i / /9@@s9~@VV V-'' M}M M M9@@s9~@VV V ]9--- rCcU(dg[U5S:XaUS$SSjnUSn[USS5H nU"X25nM U$)aTCompose wrappers into middleware stack (first = outermost). Args: wrappers: Wrappers in middleware order. Returns: Composed wrapper, or `None` if empty. Example: wrapper = _chain_tool_call_wrappers([auth, cache, retry]) # Request flows: auth -> cache -> retry -> tool # Response flows: tool -> retry -> cache -> auth NrErc(^^SUU4SjjnU$)z-Compose two wrappers where outer wraps inner.c(>^SUU4SjjnT"X5$)Nc>T"UT5$rGr`rSexecuterUs rA call_innerT_chain_tool_call_wrappers..compose_two..composed..call_innersS'**rCrSr:rYToolMessage | Commandr`rJrrrUr\s ` rAr]@_chain_tool_call_wrappers..compose_two..composeds  + +- -rC)rJr:rz2Callable[[ToolCallRequest], ToolMessage | Command]rYrr`ras`` rArb._chain_tool_call_wrappers..compose_twos. .$ .G .# . .rCrd)r\r;rUr;rYr;rkwrappersrbr>wrappers rA_chain_tool_call_wrappersrsV  8}{"b\FHSbM*W-+ MrCcU(dg[U5S:XaUS$SSjnUSn[USS5H nU"X25nM U$)zCompose async wrappers into middleware stack (first = outermost). Args: wrappers: Async wrappers in middleware order. Returns: Composed async wrapper, or `None` if empty. NrErc(^^SUU4SjjnU$)z3Compose two async wrappers where outer wraps inner.cD>^# SUU4SjjnT"X5IShvN $N7f)Nc2># T"UT5IShvN $N7frGr`rs rArZ_chain_async_tool_call_wrappers..compose_two..composed..call_inners"30000s rr`rs ` rAr]F_chain_async_tool_call_wrappers..compose_two..composeds#  1 1w33 33s   )rJr:rz=Callable[[ToolCallRequest], Awaitable[ToolMessage | Command]]rYrr`ras`` rArb4_chain_async_tool_call_wrappers..compose_twos. 4$ 4R 4# 4 4rCrd)r\|Callable[[ToolCallRequest, Callable[[ToolCallRequest], Awaitable[ToolMessage | Command]]], Awaitable[ToolMessage | Command]]rUrrYrrkrs rA_chain_async_tool_call_wrappersrst,  8}{    :b\FHSbM*W-+ MrCr`F) system_promptrr state_schemacontext_schema checkpointerstoreinterrupt_beforeinterrupt_afterdebugnamecachec ^^^B^C^D^E^F^G^H^I^J^K[T[5(a [T5mUc/nUcSmHO?[U[[45(aUmHO![U[ 5(aUmHO [ US9mHSn[TH[ 5(a[THR S9nO[TH[5(aTHn0mIU(aBURH2n[R"U5nUTIURR'M4 UVVs/sHn[US/5HnUPM M nnnUVs/sHUnURR[RLd)URR [R LdMSUPMW nnSnU(a'UVs/sHnURPM nn[#U5nUVs/sHUnURR [R Ld)URR[RLdMSUPMW nnSnU(a'UVs/sHnUR PM nn[%U5nSmJUVs/sHn[U[&5(dMUPM nnUVs/sHn[U[&5(aMUPM nnUU-nU(a [)UUUS9OSmJTJ(a'[+TJR,R/55U-mGO [+U5mG[1UVs1sHnURiM sn5[1U5:XdS5eUVs/sHUnURR2[R2Ld)URR4[R4LdMSUPMW nnUVs/sHUnURR6[R6Ld)URR8[R8LdMSUPMW nnUVs/sHUnURR:[R:Ld)URR<[R<LdMSUPMW nnUVs/sHUnURR>[R>Ld)URR@[R@LdMSUPMW n nUVs/sHUnURRB[RBLd)URRD[RDLdMSUPMW n!nUVs/sHUnURRD[RDLd)URRB[RBLdMSUPMW n"nSmKU!(a'U!Vs/sHnURBPM n#n[GU#5mKSmFU"(a'U"Vs/sHnURDPM n$n[IU$5mFUVs1sHnURJiM n%nUbUO[Ln&U%ROU&5 [QU%SS5n'[QU%SS5n([QU%S S 5n)[SU'U(U)US 9n*S)UI4S jjmES*UIUJ4S jjmDS+UDUE4SjjmCS,UCUGUHUUUK4Sjjn+S+UDUE4SjjmBS,UBUFUGUHUU4Sjjn,U*RUS[WU+U,SS95 TJbU*RUSTJ5 UGHnURR2[R2Ld'URR4[R4LaURR2[R2La UR2OSn-URR4[R4La UR4OSn.[WU-U.SS9n/U*RUURS3U/U'S9 URR6[R6Ld'URR8[R8LaURR6[R6La UR6OSn0URR8[R8La UR8OSn1[WU0U1SS9n2U*RUURS3U2U'S9 URR:[R:Ld'URR<[R<LaURR:[R:La UR:OSn3URR<[R<La UR<OSn4[WU3U4SS9n5U*RUURS3U5U'S9 URR>[R>Ld*URR@[R@LdGMURR>[R>La UR>OSn6URR@[R@La UR@OSn7[WU6U7SS9n8U*RUURS3U8U'S9 GM U(aUSRS3n9OU(aUSRS3n9OSn9U(aUSRS3n:OSn:U(aUSRS3n;OSn;U (aU SRS3nU(dU;S:waU>RaU:5 U*RcU;[W[gU:TIU5 Oy[1TI5S:a&U*RcU;[W[iU:U str: '''Return the weather forecast for the specified location.''' return f"It's always sunny in {location}" graph = create_agent( model="anthropic:claude-sonnet-4-5-20250929", tools=[check_weather], system_prompt="You are a helpful assistant", ) inputs = {"messages": [{"role": "user", "content": "what is the weather in sf"}]} for chunk in graph.stream(inputs, stream_mode="updates"): print(chunk) ``` Nrtools)rwrap_tool_callawrap_tool_callz-Please remove duplicate middleware instances. StateSchema InputSchemainput OutputSchemaoutput)r input_schema output_schemarc z>[U[5(aNUR(d8[R"UR 5nUR U5nU/US.$SU/0$[U[5(Ga[U[5(GaUR(aURVs/sHowST;dM UPM nnU(aSn [U5S:a]UVs/sHowSPM n n[X5n [X5upU (dU eUVs/sHn[!U USUSS 9PM n nSU/U Q0$US nTUSnUR US 5nUR"(a UR"OS U3nU[!UUSUSS 9/US.$SU/0$![a4n[UR RSS5n[XTU5nUeSnAff=fs snfs snfs snf![aDn[USX@5n [X5upU (dU eSU[!U USUSS 9/0sSnA$SnAff=f) zHandle model output including structured responses. Args: output: The AI message output from the model. effective_response_format: The actual strategy used (may differ from initial if auto-detected). )messagesr?__name__rNrrrEid)content tool_call_idrrargszReturning structured response: )r@r+ tool_callsr,from_schema_spec schema_specparserrrr/r0r rlr)rrtool_message_content)reffective_response_formatprovider_strategy_bindingr?excrvalidation_errortcstructured_tool_callsr tool_names should_retry error_message tool_messages tool_callstructured_tool_bindingrstructured_output_toolss rA_handle_model_output*create_agent.._handle_model_output/s /1A B B$$,C,T,T-99-) ^*C*I*I&*Q'*0I\]]) ) 0, ? ?69--!!$..%.rV*@W2W. "%%:> ,-17L!M7LV*7LJ!M >z RI2Q!3/L('#8 % #8B $$1)+D!#F #8 "%'(@-(@AA2!4 &.EiPVFW.X+*A*G*G RXHY*Z'5II2FF>?R>ST)#'(<-6t_%.v%6%0C  <VH%%k!+")1==DDjRc#K(G{Y_'`$** + %"N%B! ? &@QSV _I2Q!3/L('#"'(5-6t_%.v%6%  sO F0 GG$G"G'AG, G&/GG, H:69H5/H:5H:c>0nT(aTRR5n/nURH^n[U[5(aM[U[ 5(dM1UR U;dMCURUR 5 M` U(a-[UR55nSUSUS3n[U5e[UR[5(aV[UR5(a[URR S9nO*[#URR S9nO URn[%UR5n[U["5(a:T R'5Vs/sHoR(PM n nUR+U 5 [U[5(a=UR-5n URR."U4SS0U DUR0D6U4$[U["5(a~UR2H.n U R T ;dMSU R S3n[U5e T (aS O UR4n URR."U4S U 0UR0D6U4$U(a5URR."U4S UR40UR0D6S 4$URR6"S 0UR0D6S 4$s snf) aGet the model with appropriate tool bindings. Performs auto-detection of strategy if needed based on model capabilities. Args: request: The model request containing model, tools, and response format. Returns: Tuple of `(bound_model, effective_response_format)` where `effective_response_format` is the actual strategy used (may differ from initial if auto-detected). z(Middleware returned unknown tool names: z Available client-side tools: aZ To fix this issue: 1. Ensure the tools are passed to create_agent() via the 'tools' parameter 2. If using custom middleware with tools, ensure they're registered via middleware.tools attribute 3. Verify that tool names in ModelRequest.tools match the actual tool.name values Note: Built-in provider tools (dict format) can be added dynamically.rstrictTzToolStrategy specifies tool 'zP' which wasn't declared in the original response format when creating the agent.r tool_choiceNr`) tools_by_namecopyrr@dictrrappendsortedkeys ValueErrorrr(rrr+rr0rvaluestoolextendto_model_kwargs bind_toolsmodel_settings schema_specsr bind)rJavailable_tools_by_nameunknown_tool_namestavailable_tool_namesmsgr final_toolsinfostructured_toolskwargsrr r tool_nodes rA_get_bound_model&create_agent.._get_bound_models #% &/&=&=&B&B&D # A!T""!X&&1669P+P"))!&&1  #)*A*F*F*H#I :;M:NO00D/EFX X S/ ! g--| < <*7==99, >6M6T6T6VW6Vd 6V W   / 0 /1A B B.>>@F (((,06:A:P:P*   / > >0<<77"997yACC %S/)=$;%@S@SK ((-8T"U5upURnUR(a[UR5/UQnURU5nT "XB5nUSnUR S5n[ UUS9$)zExecute model and return response. This is the core model execution logic wrapped by `wrap_model_call` handlers. Raises any exceptions that occur during model invocation. rr?r=)rrrinvokegetr" rJmodel_rrrhandled_output messages_listr?r&rs rA_execute_model_sync)create_agent.._execute_model_sync s-=W,E)##  %g&;&;<HxHHx(.fP&z2 ,001FG 3  rCc >[TTT TUSSUUS9nT c T"U5nO T "UT5nSUR0nURbURUS'U$)zASync model request handler with sequential middleware processing.rNrrrrrr stateruntimer?r!r>r?) r3r4rJresponse state_updatesr/ default_toolsinitial_response_formatrrwrap_model_call_handlers rA model_node create_agent..model_node"s~'3:&   # **73H/w8KLH$X__5  ' ' 33;3O3OM/ 0rCc># T"U5upURnUR(a[UR5/UQnURU5IShvN nT "XB5nUSnUR S5n[ UUS9$N,7f)zExecute model asynchronously and return response. This is the core async model execution logic wrapped by `wrap_model_call` handlers. Raises any exceptions that occur during model invocation. Nrr?r=)rrrainvoker*r"r+s rA_execute_model_async*create_agent.._execute_model_async=s-=W,E)##  %g&;&;<HxHH~~h//.fP&z2 ,001FG 3  0sABB-Bc ># [T TT TUSSUUS9nTcT"U5IShvN nOT"UT5IShvN nSUR0nURbURUS'U$NBN27f)zBAsync model request handler with sequential middleware processing.rNr2r?r5) r3r4rJr6r7r?awrap_model_call_handlerr8r9rrs rA amodel_node!create_agent..amodel_nodeWs'3:&   $ +1'::H6g?STTH$X__5  ' ' 33;3O3OM/ 0;Us"A,A(A,A*1A,*A,rFtracez .before_agent)rz .before_modelz .after_modelz .after_agentrrdc38# UHoRv M g7frG) return_direct)rrs rArcreate_agent..sP/Ot""/Os)r%model_destinationrend_destination)rJrrKrJrK after_model)rdefault_destinationrJrK can_jump_to before_agent before_modelrE after_agent)rrrrrrrrecursion_limiti')rr rzResponseFormat | NonerYdict[str, Any])rJr!rYz&tuple[Runnable, ResponseFormat | None])rJr!rYr")r3rr4zRuntime[ContextT]rYrT)6CCO#4#E#Eo#V FZ #$8$=$=$B$B C D$.O:awq'27N!7N:O#A ;; % %_-K-K K ;; & &o.M.M M  #"".IJ.IA$$.IJ!:8!D$A ;; & &o.M.M M ;; % %_-K-K K !$##5QR5Q!++5QR"A."Q"&I!&>A*Q*=aN> %A1Z4-@QMA'6O  !13 Y44;;=>O ^,   + 1 + ,J ?7 ? !A ;; # #?+G+G G ;; $ $O,I,I I !!A ;; # #?+G+G G ;; $ $O,I,I I ! A ;; " "/*E*E E ;; # #?+G+G G   A ;; " "/*E*E E ;; # #?+G+G G  $A ;; & &o.M.M M ;; ' '/O/O O !$%A ;; ' '/O/O O ;; & &o.M.M M "%##4PQ4Pq**4P Q"<]"K $$6ST6S!,,6ST#CN#S 8BC 1 MC!-!9zJj!+M=$O"=-IL#M>8LM *!#%   g&g&6Kg& g&RpBpBd  06  48 NN7,ZERS w * KK $ $O,H,H H{{((0M0MM ;;++?3O3OO ;;,,O4Q4QQ  !11BDV^c d  NN66(-(*;J_   KK $ $O,H,H H{{((0M0MM ;;++?3O3OO ;;,,O4Q4QQ  +; ERK NN66(-(+DY   KK # #?+F+F F{{''/K/KK ;;**/2M2MM  ;;++?3O3OO  **kOJ NNaffX\2JMbN c KK # #?+F+F F{{''/K/KK ;;**/2M2MM  ;;++?3O3OO  00@BS[`a  NN66(,')9H]  _h!1!499:-H "1!499:-H  !6q9>>?}M! 4Q7<<=\J  /3889F   NN5*%(7&7# Py/F/F/M/M/OP P P& ' . .y 9 ##  )'&5,C$-    ( ((/ &:# n7 ' . . ? ##  )&5,C$-    (  $ % ) ##  )&5$-  i (  7 " ~y1  ,Q/445\B )-%()A!)DmT  !(()BCFB y .')wwi}$="1 ),R@  D  -b1667}E /-%()B2)FW  !(()BCFB y .')wwi}$="1 ),R@  D  -b1667}E '-%()B2)FW    w#;B#?#D#D"E\ RS56:ArBC)#.B)#'2B y -')wwi|$<"1 ),R?  C 56:ArBC)#.B)#'2B y -')wwi|$<"1 ),R?  C  ,Q/445\B #-%()A!)DmT   ==!)'   k$f-./KP #K $S ?A4,! !    $%R U Ds !y.1Ay4y4y9Ay>y>.zz4zz z z5Az zAz-z9Az!z!Az&1z&=Az+z+Az05z0 z5:z:!z?c2US:XaU$US:XaU$US:Xagg)Nrendrr`)jump_torJrKs rA _resolve_jumprs. '  %' rCc[[U5S- SS5H,n[X[5(dMUn[ SX5n O UWS-SVs/sHn[U[ 5(dMUPM nnWU4$s snf)NrErdr )rerlr@r rr)ri last_ai_indexlast_ai_messagerkrs rA _fetch_last_ai_and_tool_messagesrs 3x=1$b" - hk9 - -M"; URS5=n(a [UT T S9$[US5up#UVs/sHoDRPM nn[ UR 5S:XaT $UR Vs/sHnUSU;dMUST ;dMUPM nnU(a&UVs/sHn[ S[SUUS 95PM sn$S U;aT $T $s snfs snfs snf) NrrLrrrrrtool_call_with_context)__typerr3r?)r*rrrrlrrr) r3rrrrktool_message_idscpending_tool_callsrrKrJrs rAmodel_to_tools1_make_model_to_tools_edge..model_to_toolss+ii * *7 * "3 /  *J%PZJ[)\&4ABMqNNMB )) *a /" "%// /w.. 34V9D[3[ /   "4 "4I'7"+#"4   !E )" "! CC  sC9 C CC(Cr3rTrYzstr | list[Send] | Noner`)rJrrKrs``` rAr`r`s& -!-! -!-!^ rCc$^^SUU4SjjnU$)Nc^>URS5=n(a [UTTS9$SU;aT$T$)NrrLr?)r*r)r3rrKrJs rAmodel_to_model1_make_model_to_model_edge..model_to_modelsGii * *7 * "3 /  !E )" "! rCrr`)rJrKrs`` rAraras% !! !!& rCc$^^^^SUUUU4SjjnU$)Nc>[US5upURVs/sHo3STR;dMUPM nnU(a[U4SjU55(aT$[ U4SjU55(aT$T$s snf)Nrrc3\># UH!nTRUSRv M# g7f)rN)r rH)rrr%s rArD_make_tools_to_model_edge..tools_to_model..s** F\I # #AfI . < # UHoRT;v M g7frG)r)rrrs rArrsH-Qvv00-s)rrr allr) r3rrrclient_side_tool_callsrKrJrr%s rAtools_to_model1_make_tools_to_model_edge..tools_to_model s)I%PZJ[)\& '11" 1!vY)BYBY5YA1 "  "c* F\* ' ' # " H-H H H" " ! " s BB)r3rTrY str | Noner`)r%rJrrKrs```` rAr_r_s!!, rCc$^^^U(atSUUU4SjjnT/nSU;aURT5 SU;aURS5 SU;aUT:waURT5 URU[USS9U5 gURUT5 g) aAdd an edge to the graph for a middleware node. Args: graph: The graph to add the edge to. name: The name of the middleware node. default_destination: The default destination for the edge. model_destination: The destination for the edge to the model. end_destination: The destination for the edge to the end. can_jump_to: The conditionally jumpable destinations for the edge. cJ>[URS5TTS9=(d T$)NrrL)rr*)r3rNrKrJs rA jump_edge'_add_middleware_edge..jump_edge;s,IIi(&7$3' '  rCrrrFrEN)r3rTrYr)rr^rr])rrrNrJrKrOr destinationss ``` rArbrb$s*  ,, K     0 k !    ( k !d.?&?    1 2 ##D*:9E*RT`a t01rCr)r>zModelResponse | AIMessagerYr")rozfSequence[Callable[[ModelRequest, Callable[[ModelRequest], ModelResponse]], ModelResponse | AIMessage]]rYzWCallable[[ModelRequest, Callable[[ModelRequest], ModelResponse]], ModelResponse] | None)roz|Sequence[Callable[[ModelRequest, Callable[[ModelRequest], Awaitable[ModelResponse]]], Awaitable[ModelResponse | AIMessage]]]rYzmCallable[[ModelRequest, Callable[[ModelRequest], Awaitable[ModelResponse]]], Awaitable[ModelResponse]] | NonerG)rz set[type]rrrrrYr)rrrYr)rzAgentMiddleware[Any, Any]rrrYz list[JumpTo])rstr | BaseChatModelrYbool)rrrr-rYztuple[bool, str])rzSequence[ToolCallWrapper]rYzToolCallWrapper | None)rzSequence[Callable[[ToolCallRequest, Callable[[ToolCallRequest], Awaitable[ToolMessage | Command]]], Awaitable[ToolMessage | Command]]]rYzCallable[[ToolCallRequest, Callable[[ToolCallRequest], Awaitable[ToolMessage | Command]]], Awaitable[ToolMessage | Command]] | None)rrrz5Sequence[BaseTool | Callable | dict[str, Any]] | Nonerrrz.Sequence[AgentMiddleware[StateT_co, ContextT]]rz2ResponseFormat[ResponseT] | type[ResponseT] | Nonerz"type[AgentState[ResponseT]] | Nonerztype[ContextT] | NonerzCheckpointer | NonerzBaseStore | Nonerlist[str] | NonerrrrrrrzBaseCache | NonerYzcCompiledStateGraph[AgentState[ResponseT], ContextT, _InputAgentState, _OutputAgentState[ResponseT]])rz JumpTo | NonerJrrKrrYr)rzlist[AnyMessage]rYz#tuple[AIMessage, list[ToolMessage]])rJrrdict[str, OutputToolBinding]rKrrY3Callable[[dict[str, Any]], str | list[Send] | None])rJrrKrrYr) r%rrJrrrrKrrYz&Callable[[dict[str, Any]], str | None])rz[StateGraph[AgentState[ResponseT], ContextT, _InputAgentState, _OutputAgentState[ResponseT]]rrrNrrJrrKrrOzlist[JumpTo] | NonerYNone)b__doc__ __future__rrctypingrrrrrr r *langchain_core.language_models.chat_modelsr langchain_core.messagesr r rrlangchain_core.toolsrlanggraph._internal._runnablerlanggraph.constantsrrlanggraph.graph.staterlanggraph.prebuilt.tool_noderrlanggraph.runtimerlanggraph.typesrrlanggraph.typingrtyping_extensionsrrr!langchain.agents.middleware.typesrrr r!r"r#r$r%r&r'"langchain.agents.structured_outputr(r)r*r+r,r-r.r/r0langchain.chat_modelsr1collections.abcr2r3r4langchain_core.runnablesr5langgraph.cache.baser6r7langgraph.store.baser8r9r:r;rrBrprrrrrrrrrrrr`rar_rb__all__r`rCrArs%@"EUU):*,F%)%>>      2==1.8.,R#O mm m`RR Rj3>  F.#<+'++\== =DDHL/!%ACJN7;,0(,")-(,"L/ L/ @L/ L/ ? L/ H L/5L/*L/&L/ L/'L/&L/ L/ L/ L/ !L/^        * *( * 55:5 5 9 5p9 6:    , @-2 -2  -2  -2-2-2%-2 -2b rC