OKiSrSSKJr SSKrSSKJrJr SSKJrJ r J r J r J r J r JrJr SSKJr SSKJrJrJrJr SSKJr SS KJr SS KJrJr SS KJr SS K J!r!J"r" SS K#J$r$J%r% SSK&J'r'J(r(J)r) SSK*J+r+J,r,J-r-J.r.J/r/J0r0J1r1J2r2J3r3J4r4J5r5J6r6 SSK7J8r8J9r9J:r:J;r;Jr>J?r?J@r@ SSKAJBrB \"SS\ \355rC\(aSSKDJErEJFrFJGrG SSKHJIrIJJrJ SSKKJLrL SSKJMrM SSKNJOrO SSKPJQrQ SSK#JRrR SSK*JSrSJTrT \F\0\-\F\0\-/\14/\1\-\.-4rU\F\0\-\F\0\-/\14/\C4rV\F\0\-\F\0\-/\E\14/\E\1\-\.-4rW\F\0\-\F\0\-/\E\14/\E\C4rXSrYSR5r[/SQr\S5Sjr]S6S7S jjr^S8S!jr_S9S"jr`S6S:S#jjraS;S$jrbSS'jreS?S(jrfS@S)jrgS6SS*SSSSSSSS+SSS,. SAS-jjjrhSBS.jriSCS/jrjSDS0jrkSES1jrlSFS2jrmSGS3jrnS4/rog)Hz:Agent factory for creating agents with middleware support.) annotationsN) dataclassfield) TYPE_CHECKING AnnotatedAnyGenericcastget_args get_originget_type_hints) BaseChatModel) AIMessage AnyMessage SystemMessage ToolMessage)BaseTool)RunnableCallable)ENDSTART) StateGraph)ToolCallWithContextToolNode)CommandSend) NotRequiredRequired TypedDict) AgentMiddleware AgentStateContextTExtendedModelResponseJumpTo ModelRequest ModelResponseOmitFromSchema ResponseT StateT_co_InputAgentState_OutputAgentState) AutoStrategyMultipleStructuredOutputsErrorOutputToolBindingProviderStrategyProviderStrategyBindingResponseFormatStructuredOutputErrorStructuredOutputValidationError ToolStrategy)init_chat_modelc<\rSrSr%SrS\S'\"\S9rS\S'Sr g ) _ComposedExtendedModelResponse8zInternal result from composed ``wrap_model_call`` middleware. Unlike ``ExtendedModelResponse`` (user-facing, single command), this holds the full list of commands accumulated across all middleware layers during composition. zModelResponse[ResponseT]model_response)default_factorylist[Command[Any]]commandsN) __name__ __module__ __qualname____firstlineno____doc____annotations__rlistr;__static_attributes__r<Z/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/langchain/agents/factory.pyr6r68s%-,(#(#>H >TrEr6) AwaitableCallableSequence)RunnableRunnableConfig) BaseCache)CompiledStateGraph)Runtime) BaseStore) Checkpointer)ToolCallRequestToolCallWrapperz)Error: {error} Please fix your mistakes.a Middleware added tools that the agent doesn't know how to execute. Unknown tools: {unknown_tool_names} Registered tools: {available_tool_names} This happens when middleware modifies `request.tools` in `wrap_model_call` to include tools that weren't passed to `create_agent()`. How to fix this: Option 1: Register tools at agent creation (recommended for most cases) Pass the tools to `create_agent(tools=[...])` or set them on `middleware.tools`. This makes tools available for every agent invocation. Option 2: Handle dynamic tools in middleware (for tools created at runtime) Implement `wrap_tool_call` to execute tools that are added dynamically: class MyMiddleware(AgentMiddleware): def wrap_tool_call(self, request, handler): if request.tool_call["name"] == "dynamic_tool": # Execute the dynamic tool yourself or override with tool instance return handler(request.override(tool=my_dynamic_tool)) return handler(request) )grokzgpt-5zgpt-4.1zgpt-4ozgpt-osszo3-prozo3-minic[U[5(a [U/SS9$[U[5(a UR$U$)zNormalize middleware return value to ModelResponse. At inner composition boundaries, ``ExtendedModelResponse`` is unwrapped to its underlying ``ModelResponse`` so that inner middleware always sees ``ModelResponse`` from the handler. Nresultstructured_response) isinstancerr%r"r8)rVs rF_normalize_to_model_responserYs?&)$$VH$GG&/00$$$ MrEczSUR0nURbURUS'U=(d /H]nUR(a Sn[U5eUR(a Sn[U5eUR (dMRSn[U5e [ US9/nURU=(d /5 U$)aBuild a list of Commands from a model response and middleware commands. The first Command contains the model response state (messages and optional structured_response). Middleware commands are appended as-is. Args: model_response: The model response containing messages and optional structured output. middleware_commands: Commands accumulated from middleware layers during composition (inner-first ordering). Returns: List of ``Command`` objects ready to be returned from a model node. messagesrWzCommand goto is not yet supported in wrap_model_call middleware. Use the jump_to state field with before_model/after_model hooks instead.zBCommand resume is not yet supported in wrap_model_call middleware.zACommand graph is not yet supported in wrap_model_call middleware.)update)rVrWgotoNotImplementedErrorresumegraphrextend)r8middleware_commandsstatecmdmsgr;s rF_build_commandsrfs$()>)>?E))5'5'I'I#$"(b( 88[ &c* * ::VC%c* * 999UC%c* *)%,5$9#:H OO'-2. OrEc^^U(dgS S Sjjm[U5S:XaUSmS UU4SjjnU$S U4SjjnU"USUS5n[USS5H nU"XC5nM U$) 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. Commands from each layer are accumulated into a list (inner-first, then outer) without merging. Args: handlers: List of handlers. First handler wraps all others. Returns: Composed handler returning ``_ComposedExtendedModelResponse``, or ``None`` if handlers empty. Nc`[U=(d /5n[U[5(a(URUR5 UR nOU[U[ 5(a5UR nURbURUR5 O [U5n[X2S9$z?Normalize any handler result to _ComposedExtendedModelResponse.)r8r; rCrXr6rar;r8r"commandappendrYrVextra_commandsr;r8s rF_to_composed_result7_chain_model_call_handlers.._to_composed_result (,N,@b'A f< = = OOFOO ,#22N  5 6 6#22N~~)/9&AN-^__rErc >T"T"X55$Nr<requesthandlerrosingle_handlers rFnormalized_single5_chain_model_call_handlers..normalized_singles'~g'GH HrEc,>^^SUUU4SjjnU$)z-Compose two handlers where outer wraps inner.cP>^^/mSUUU4SjjnT"X5nT"UT=(d SS9$)NcV>TR5 T"UT5n[U[5(a'TRUR5 UR $[U[ 5(a4URbTRUR5 UR $[U5$rt clearrXr6rar;r8r"rkrlrYreq inner_resultaccumulated_commandsrwinners rF inner_handlerX_chain_model_call_handlers..compose_two..composed..inner_handler s$**,$S'2 l,JKK(// 0E0EF'666l,ABB#++7,33L4H4HI'6663LAArErnrModelRequest[ContextT]returnr%r<rvrwr outer_resultrrorouters ` @rFcomposedA_chain_model_call_handlers..compose_two..composeds; 8:  B B!8L&3;t rErvrrwz1Callable[[ModelRequest[ContextT]], ModelResponse]rr6r<rrrros`` rF compose_two/_chain_model_call_handlers..compose_twos.  + F ,  4rErtrVzRModelResponse | AIMessage | ExtendedModelResponse | _ComposedExtendedModelResponsernlist[Command[Any]] | Nonerr6r)rA_ModelCallHandler[ContextT] | _ComposedModelCallHandler[ContextT]rrrz#_ComposedModelCallHandler[ContextT]lenreversedhandlersryrcomposed_handlerhrorxs @@rF_chain_model_call_handlersrs$ 59`b`1` (`$ 8}!! I+ IF I, I I !  P P  - F#8B<"> hsm $&q;% rEc^^U(dgS S Sjjm[U5S:XaUSmS UU4SjjnU$S U4SjjnU"USUS5n[USS5H nU"XC5nM U$) aCompose multiple async ``wrap_model_call`` handlers into single middleware stack. Commands from each layer are accumulated into a list (inner-first, then outer) without merging. Args: handlers: List of async handlers. First handler wraps all others. Returns: Composed async handler returning ``_ComposedExtendedModelResponse``, or ``None`` if handlers empty. Nc`[U=(d /5n[U[5(a(URUR5 UR nOU[U[ 5(a5UR nURbURUR5 O [U5n[X2S9$rirjrms rFro=_chain_async_model_call_handlers.._to_composed_result<rqrErrrc<># T"T"X5IShvN 5$N7frtr<rus rFry;_chain_async_model_call_handlers..normalized_singleQs'^G-M'MN N'Ms  c,>^^SUUU4SjjnU$)z3Compose two async handlers where outer wraps inner.cl>^^# /mSUUU4SjjnT"X5IShvN nT"UT=(d SS9$N7f)Ncr># TR5 T"UT5IShvN n[U[5(a'TRUR5 UR $[U[ 5(a4URbTRUR5 UR $[U5$N7frtr~rs rFr^_chain_async_model_call_handlers..compose_two..composed..inner_handlerfs$**,%*3%88 l,JKK(// 0E0EF'666l,ABB#++7,33L4H4HI'6663LAA 9sB7B5BB7rrr<rs ` @rFrG_chain_async_model_call_handlers..compose_two..composed_sF 8:  B B"'w!>>L&3;t ?s 424rvrrwz.compose_twoYs.  + Q ,  4rErrrtrr)rK_AsyncModelCallHandler[ContextT] | _ComposedAsyncModelCallHandler[ContextT]rrrz(_ComposedAsyncModelCallHandler[ContextT]rrs @@rF _chain_async_model_call_handlersr(s" 59`b`1` (`$ 8}!! O+ OQ O, O O !  Z Z  2 F#8B<"> hsm $&q;% rEc0nUHyn[USS9nUR5HXupgSnU(a=[U5n U H,n [U [5(dM[ X5SLdM*Sn O U(aMTXsU'MZ M{ [ X5$)aIResolve 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'`) Returns: Merged schema as `TypedDict` T)include_extrasF)r items_extract_metadatarXr&getattrr) schemas schema_name omit_flagall_annotationsschemahints field_name field_type should_omitmetadatametas rF_resolve_schemarsOvd;&+kkm "JK,Z8$D!$77GD# UHoTR5;v M g7frt)lower).0partrs rF ._supports_provider_strategy..s Z3Y4J$$& &3Ys"F) rXstrrrprofilegetrany&FALLBACK_MODELS_WITH_STRUCTURED_OUTPUT)rtools model_profilers @rF_supports_provider_strategyrs"J% E= ) ) E< . .ugt, .uj"-    %!!"566z*c::x:K[K[K]?]  Z3Y ZZrEc0^[U[5(dgURnUSLagUSLaS[R [ T5S94$[U[ 5(aSU4$[U[ 5(aE[U[5(a/[TU5(aS[R [ T5S94$g[U[5(a9[U4SjU55(aS[R [ T5S94$gSU"T54$)zOHandle structured output error. Returns `(should_retry, retry_tool_message)`. )FrFT)errorc3<># UHn[TU5v M g7frt)rX)rexc_type exceptions rFr2_handle_structured_output_error..sM}8z)X..}s) rXr3 handle_errors STRUCTURED_OUTPUT_ERROR_TEMPLATEformatrtype issubclass Exceptiontupler)rresponse_formatrs` rF_handle_structured_output_errorrs o| 4 4#11M5<<3y><RRR-%%]""-&& mY / /Jy-4X4X9@@s9~@VV V-'' M}M M M9@@s9~@VV V y) ))rEcU(dg[U5S:XaUS$SSjnUSn[USS5H nU"X25nM U$)ajCompose wrappers into middleware stack (first = outermost). Args: wrappers: Wrappers in middleware order. Returns: Composed wrapper, or `None` if empty. Example: ```python wrapper = _chain_tool_call_wrappers([auth, cache, retry]) # Request flows: auth -> cache -> retry -> tool # Response flows: tool -> retry -> cache -> auth ``` Nrrrc(^^SUU4SjjnU$)z-Compose two wrappers where outer wraps inner.c(>^SUU4SjjnT"X5$)Nc>T"UT5$rtr<rexecuters rF call_innerT_chain_tool_call_wrappers..compose_two..composed..call_inner=sS'**rErrQrToolMessage | Command[Any]r<rvrrrrs ` rFr@_chain_tool_call_wrappers..compose_two..composed8s  + +- -rE)rvrQrz7Callable[[ToolCallRequest], ToolMessage | Command[Any]]rrr<rrrs`` rFr._chain_tool_call_wrappers..compose_two5s. .$ .L .( . .rEr)rrRrrRrrRrwrappersrrVwrappers rF_chain_tool_call_wrappersrsV$  8}{"b\FHSbM*W-+ MrEcU(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. Nrrrc(^^SUU4SjjnU$)z3Compose two async wrappers where outer wraps inner.cD>^# SUU4SjjnT"X5IShvN $N7f)Nc2># T"UT5IShvN $N7frtr<rs rFrZ_chain_async_tool_call_wrappers..compose_two..composed..call_inner}s"30000s rr<rs ` rFrF_chain_async_tool_call_wrappers..compose_two..composedxs#  1 1w33 33s   )rvrQrzBCallable[[ToolCallRequest], Awaitable[ToolMessage | Command[Any]]]rrr<rs`` rFr4_chain_async_tool_call_wrappers..compose_twois. 4$ 4W 4( 4 4rEr)rCallable[[ToolCallRequest, Callable[[ToolCallRequest], Awaitable[ToolMessage | Command[Any]]]], Awaitable[ToolMessage | Command[Any]]]rr rr rrs rF_chain_async_tool_call_wrappersr Mst,  8}{    :b\FHSbM*W-+ MrEr<F) system_promptrr state_schemacontext_schema checkpointerstoreinterrupt_beforeinterrupt_afterdebugnamecachec 8^^ ^A^B^C^D^E^F^G^H^I^J^K^L^M^N[T[5(a [T5mSmJUb![U[5(aUmJO [US9mJUc/nUcSmHO?[U[[ 45(aUmHO![U[ 5(aUmHO [ US9mHSmL[TH[ 5(a[ THRS9mLO[TH[5(aTHmL0mITL(aBTLRH2n[R"U5nUTIURR'M4 UVVs/sHn[US/5HnUPM M nnnUVs/sHUnURR[ RLd)URR"[ R"LdMSUPMW nnSmNU(a'UVs/sHnURPM nn[%U5mNUVs/sHUnURR"[ R"Ld)URR[ RLdMSUPMW nnSmFU(a'UVs/sHnUR"PM nn['U5mFSmKUVs/sHn[U[(5(dMUPM nnUVs/sHn[U[(5(aMUPM nnUU-nU(dTN(dTF(a [+UTNTFS9OSmKTK(a'[-TKR.R155U-mGO [-U5mG[3UVs1sHnURiM sn5[3U5:wa Sn[5U5eUVs/sHUnURR6[ R6Ld)URR8[ R8LdMSUPMW nnUVs/sHUnURR:[ R:Ld)URR<[ R<LdMSUPMW nnUVs/sHUnURR>[ R>Ld)URR@[ R@LdMSUPMW nnUVs/sHUnURRB[ RBLd)URRD[ RDLdMSUPMW nnUVs/sHUnURRF[ RFLd)URRH[ RHLdMSUPMW nnUVs/sHUnURRH[ RHLd)URRF[ RFLdMSUPMW n nSmMU(a'UVs/sHnURFPM n!n[KU!5mMSmEU (a'U Vs/sHnURHPM n"n[MU"5mEUVs1sHnURNiM n#nUbUO[Pn$U#RSU$5 [UU#SS5n%[UU#SS 5n&[UU#S S 5n'[WU%U&U'US 9n(S,UI4S jjmDS-UFUHUIUKULUN4SjjmCS.UCUDU 4SjjmBS/UBUGUHUUJUM4Sjjn)S.UCUDU 4SjjmAS/UAUEUGUHUUJ4Sjjn*U(RYS[[U)U*SS95 TKbU(RYSTK5 UGHnURR6[ R6Ld'URR8[ R8LaURR6[ R6La UR6OSn+URR8[ R8La UR8OSn,[[U+U,SS9n-U(RYURS3U-U%S9 URR:[ R:Ld'URR<[ R<LaURR:[ R:La UR:OSn.URR<[ R<La UR<OSn/[[U.U/SS9n0U(RYURS3U0U%S9 URR>[ R>Ld'URR@[ R@LaURR>[ R>La UR>OSn1URR@[ R@La UR@OSn2[[U1U2SS9n3U(RYURS3U3U%S9 URRB[ RBLd*URRD[ RDLdGMURRB[ RBLa URBOSn4URRD[ RDLa URDOSn5[[U4U5SS9n6U(RYURS3U6U%S9 GM U(aUSRS3n7OU(aUSRS3n7OSn7U(aUSRS3n8OSn8U(aUSRS3n9OSn9U(aUSRS3n:O[\n:U(R_[`U75 TKbU8/n;[cSTKR.R1555(dTI(aU;ReU:5 U(RgS[[[iTKU8TIU:S9SS9U;5 SU:/n[oU(U=RS3U>RS3U8U:[qU=S#5S"9 M: [oU(USRS3U8U8U:[qUSS#5S"9 U(a}[rRt"U5H8un=n>[oU(U=RS3U>RS3U8U:[qU=S$5S"9 M: [oU(USRS3SU8U:[qUSS$5S"9 U(aU(R_SUSRS35 [w[3U5S%- SS5HBn?UU?n=UU?S%- n>[oU(U=RS3U>RS3U8U:[qU=S!5S"9 MD U(a[w[3U5S%- SS5HBn?UU?n=UU?S%- n>[oU(U=RS3U>RS3U8U:[qU=S&5S"9 MD [oU(USRS3[\U8U:[qUSS&5S"9 S'S(0n@T (aS)T 0W@S*'U(RyUUU U U T U S+9R{W@5$s snnfs snfs snfs snfs snfs snfs snfs snfs snfs snfs snfs snfs snfs snfs snfs snfs snf)0aCreates an agent graph that calls tools in a loop until a stopping condition is met. For more details on using `create_agent`, visit the [Agents](https://docs.langchain.com/oss/python/langchain/agents) docs. Args: model: The language model for the agent. Can be a string identifier (e.g., `"openai:gpt-4"`) or a direct chat model instance (e.g., [`ChatOpenAI`][langchain_openai.ChatOpenAI] or other another [LangChain chat model](https://docs.langchain.com/oss/python/integrations/chat)). For a full list of supported model strings, see [`init_chat_model`][langchain.chat_models.init_chat_model(model_provider)]. !!! tip "" See the [Models](https://docs.langchain.com/oss/python/langchain/models) docs for more information. tools: A list of tools, `dict`, or `Callable`. If `None` or an empty list, the agent will consist of a model node without a tool calling loop. !!! tip "" See the [Tools](https://docs.langchain.com/oss/python/langchain/tools) docs for more information. system_prompt: An optional system prompt for the LLM. Can be a `str` (which will be converted to a `SystemMessage`) or a `SystemMessage` instance directly. The system message is added to the beginning of the message list when calling the model. middleware: A sequence of middleware instances to apply to the agent. Middleware can intercept and modify agent behavior at various stages. !!! tip "" See the [Middleware](https://docs.langchain.com/oss/python/langchain/middleware) docs for more information. response_format: An optional configuration for structured responses. Can be a `ToolStrategy`, `ProviderStrategy`, or a Pydantic model class. If provided, the agent will handle structured output during the conversation flow. Raw schemas will be wrapped in an appropriate strategy based on model capabilities. !!! tip "" See the [Structured output](https://docs.langchain.com/oss/python/langchain/structured-output) docs for more information. state_schema: An optional `TypedDict` schema that extends `AgentState`. When provided, this schema is used instead of `AgentState` as the base schema for merging with middleware state schemas. This allows users to add custom state fields without needing to create custom middleware. Generally, it's recommended to use `state_schema` extensions via middleware to keep relevant extensions scoped to corresponding hooks / tools. context_schema: An optional schema for runtime context. checkpointer: An optional checkpoint saver object. Used for persisting the state of the graph (e.g., as chat memory) for a single thread (e.g., a single conversation). store: An optional store object. Used for persisting data across multiple threads (e.g., multiple conversations / users). interrupt_before: An optional list of node names to interrupt before. Useful if you want to add a user confirmation or other interrupt before taking an action. interrupt_after: An optional list of node names to interrupt after. Useful if you want to return directly or run additional processing on an output. debug: Whether to enable verbose logging for graph execution. When enabled, prints detailed information about each node execution, state updates, and transitions during agent runtime. Useful for debugging middleware behavior and understanding agent execution flow. name: An optional name for the `CompiledStateGraph`. This name will be automatically used when adding the agent graph to another graph as a subgraph node - particularly useful for building multi-agent systems. cache: An optional `BaseCache` instance to enable caching of graph execution. Returns: A compiled `StateGraph` that can be used for chat interactions. Raises: AssertionError: If duplicate middleware instances are provided. The agent node calls the language model with the messages list (after applying the system prompt). If the resulting [`AIMessage`][langchain.messages.AIMessage] contains `tool_calls`, the graph will then call the tools. The tools node executes the tools and adds the responses to the messages list as [`ToolMessage`][langchain.messages.ToolMessage] objects. The agent node then calls the language model again. The process repeats until no more `tool_calls` are present in the response. The agent then returns the full list of messages. Example: ```python from langchain.agents import create_agent def check_weather(location: str) -> 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) ``` N)contentrr)rwrap_tool_callawrap_tool_callz-Please remove duplicate middleware instances. StateSchema InputSchemainput OutputSchemaoutput)r input_schema output_schemarc d>[U[5(aNUR(d8[R"UR 5nUR U5nU/US.$SU/0$[U[5(Ga[U[5(aUR(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"=(d S U3nU[!UUSUSS 9/US.$SU/0$![a4n[UR RSS5n[XTU5nXdeSnAff=fs snfs snfs snf![aDn[USX@5n [X5upU (dXeSU[!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). )r[rWr=rNr[rrrid)r tool_call_idrrargszReturning structured response: )rXr. tool_callsr/from_schema_spec schema_specparserrrr2r3rrr,rrtool_message_content)r!effective_response_formatprovider_strategy_bindingrWexcrvalidation_errortcstructured_tool_callsr tool_names should_retry error_message tool_messages tool_callstructured_tool_bindingr,structured_output_toolss rF_handle_model_output*create_agent.._handle_model_outputs /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'2FFS<=PT=(d Tn0nT(aTRR5nU(d/nURH^n[U[5(aM[U[ 5(dM1UR U;dMCURUR 5 M` U(a8[UR55n[RUUS9n[U5eURnUb)[U[[[ 45(d [US9n[U[5(aV[#UR$URS9(a[!UR&S9nO!UTLaTbTnO[UR&S9nOUn[)UR5n [U[5(a:TR+5V s/sHoR,PM n n U R/U 5 [U[ 5(a=UR15n UR$R2"U 4SS0U DUR4D6U4$[U[5(a~UR6H.n U R T;dMSU R S3n[U5e T(aS O UR8nUR$R2"U 4S U0UR4D6U4$U (a5UR$R2"U 4S UR80UR4D6S4$UR$R:"S 0UR4D6S4$s sn f) 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). Raises: ValueError: If middleware returned unknown client-side tool names. ValueError: If `ToolStrategy` specifies tools not declared upfront. )unknown_tool_namesavailable_tool_namesNr)rstrictTzToolStrategy specifies tool 'zP' which wasn't declared in the original response format when creating the agent.r tool_choicer<) tools_by_namecopyrrXdictrrrlsortedkeysDYNAMIC_TOOL_ERROR_TEMPLATEr ValueErrorrr+r3r.rrrrCvaluestoolrato_model_kwargs bind_toolsmodel_settings schema_specsr@bind)rvhas_wrap_tool_callavailable_tools_by_namer=tr>rerr- final_toolsinfostructured_toolskwargsr1r@awrap_tool_call_wrapperinitial_response_formatr9 tool_nodetool_strategy_for_setupwrap_tool_call_wrappers rF_get_bound_model&create_agent.._get_bound_modelCs&,4N7N#% &/&=&=&B&B&D #"!# ]]a&&a**qvv=T/T&--aff5 #"'-.E.J.J.L'M$188'9)=9!o%=D >6M6T6T6VW6Vd 6V W   / 0 /1A B B.>>@F (((,06:A:P:P*   / > >0<<77"997yACC %S/)=$;%@S@SK ((-8T"U5upURnUR(aUR/UQnURU5nT (aT UlT "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. r[rWrU)r[system_messageinvokerrr% rvmodel_r-r[r!handled_output messages_listrWr[r:rs rF_execute_model_sync)create_agent.._execute_model_syncs-=W,E)##  ! !..::Hx( FK.fP&z2 ,001FG 3  rEc >[TTT TUSSUUS9nT cT"U5n[U5$T "UT5n[URUR5$)zASync model request handler with sequential middleware processing.r[Nrrr^rr[r@rcruntimer$rfr8r;) rcrhrvr8rVrd default_toolsrWrr^wrap_model_call_handlers rF model_node create_agent..model_nodesk)3:&   # *09N">2 2(2EFv44fooFFrEc># T"U5upURnUR(aUR/UQnURU5IShvN nT (aT UlT "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. Nr[rWrU)r[r^ainvokerrr%r`s rF_execute_model_async*create_agent.._execute_model_asyncs-=W,E)##  ! !..::H~~h// FK.fP&z2 ,001FG 3  0sA B B ;B c ># [T TT TUSSUUS9nTcT"U5IShvN n[U5$T"UT5IShvN n[URUR5$N@N&7f)zBAsync model request handler with sequential middleware processing.r[Nrgri) rcrhrvr8rVrpawrap_model_call_handlerrjrWrr^s rF amodel_node!create_agent..amodel_nodes)3:&   $ +#7#@@N">2 2/9MNNv44fooFF AOs!"A*A&A*A(%A*(A*rFtracez .before_agent)r"z .before_modelz .after_modelz .after_agentrrc38# UHoRv M g7frt) return_direct)rrIs rFrcreate_agent..sP/Ot""/Os)rXmodel_destinationr9end_destination)r{r9r|r{r| after_model)rdefault_destinationr{r| can_jump_to before_agent before_modelrr after_agentrecursion_limiti' lc_agent_namer)rrrrrrr)r!rr-zResponseFormat[Any] | Nonerdict[str, Any])rvrrz5tuple[Runnable[Any, Any], ResponseFormat[Any] | None])rvrrr%)rczAgentState[Any]rhzRuntime[ContextT]rr:)>rXrr4rr3r.r+rrMr-r)rIrrrrrrrr rCrrCrArHrAssertionErrorr abefore_agentr abefore_modelr~ aafter_modelr aafter_agentwrap_model_callawrap_model_callrrrr addrradd_noderradd_edgerrrladd_conditional_edges_make_tools_to_model_edge_make_model_to_tools_edge_make_model_to_model_edge_add_middleware_edger itertoolspairwiserangecompile with_config)Orrrrrrrrrrrrrrresponse_schemastructured_tool_infomrQmiddleware_toolsmiddleware_w_wrap_tool_callrmiddleware_w_awrap_tool_callasync_wrappersbuilt_in_tools regular_toolsavailable_toolsremiddleware_w_before_agentmiddleware_w_before_modelmiddleware_w_after_modelmiddleware_w_after_agentmiddleware_w_wrap_model_callmiddleware_w_awrap_model_call sync_handlersasync_handlers state_schemas base_stateresolved_state_schemar"r#r`rlrtsync_before_agentasync_before_agentbefore_agent_node sync_before async_before before_node sync_after async_after after_nodesync_after_agentasync_after_agentafter_agent_node entry_nodeloop_entry_nodeloop_exit_node exit_nodetools_to_model_destinationsmodel_to_tools_destinationsm1m2idxconfigrprdr[r:rsrVrjrWr9r^rXrYrkrZsO` ` @@@@@@@@@@@@@@rF create_agentrsf%&,0N m] 3 3*N*=AN }"& Ol4D%E F F"1 O\ 2 2"1#/o"F9=)<88".6M6T6T"U +\ : :"9AC6CCO#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 48O !13 Y44;;=>O ^,  J 'JqAFFJ '(C O;=S!!!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 *!#%   f&f&6Pf& f&PB'B >BBB  6GG(  8GG* 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  08F -t4z ==!)'   k&_P #K $S ?A6 (! !    $%R U Ds3!{A{ 1{ {-A{{{{ { *{%{%8{*3A{/ {/A{4+{47A{9 {9A{>/{>;A||A|3|| 8||c2US:XaU$US:XaU$US:Xagg)Nrendrr<)jump_tor{r|s rF _resolve_jumprGs. '  %' rEc[[U5S- SS5H[n[X[5(dM[ SX5nXS-SVs/sHn[U[ 5(dMUPM nnX$4s $ S/4$s snf)aReturn the last AI message and any subsequent tool messages. Args: messages: List of messages to search through. Returns: A tuple of (last_ai_message, tool_messages). If no AIMessage is found, returns (None, []). Callers must handle the None case appropriately. rrrrN)rrrXrr r)r[ilast_ai_messagerr6s rF _fetch_last_ai_and_tool_messagesrVs3x=1$b" - hk9 - -"; URS5=n(a [UT T S9$[US5up#UcT $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) Nrr}r[rr%rrtool_call_with_context)__typer7rcrW)rrrr&rr(rr) rcrrr6rtool_message_idscpending_tool_callsr7r|r{r9s rFmodel_to_tools1_make_model_to_tools_edge..model_to_toolsqs9ii * *7 * "3 /  *J%PZJ[)\&  "" "4ABMqNNMB )) *a /" "%// /w.. 34V9D[3[ /   "4 "4I'7"+#"4   !E )" "! CC  sC> CCC-C#rcrrzstr | list[Send] | Noner<)r{r9r|rs``` rFrrks& 2!2! 2!2!h rEc$^^SUU4SjjnU$)Nc^>URS5=n(a [UTTS9$SU;aT$T$)Nrr}rW)rr)rcrr|r{s rFmodel_to_model1_make_model_to_model_edge..model_to_modelsGii * *7 * "3 /  !E )" "! rErr<)r{r|rs`` rFrrs% !! !!& rEc$^^^^SUUUU4SjjnU$)Nc>[US5upUcT$URVs/sHo3STR;dMUPM nnU(a[U4SjU55(aT$[ U4SjU55(aT$T$s snf)Nr[rc3\># UH!nTRUSRv M# g7f)rN)rAry)rrrXs rFrD_make_tools_to_model_edge..tools_to_model..s** F\I # #AfI . < # UHoRT;v M g7frt)r)rrQr9s rFrrsH-Qvv00-s)rr(rAallr) rcrr6rclient_side_tool_callsr|r{r9rXs rFtools_to_model1_make_tools_to_model_edge..tools_to_models)I%PZJ[)\&  "$ $ '11" 1!vY)BYBY5YA1 "  "c* F\* ' ' # " H-H H H" " ! " s BB)rcrr str | Noner<)rXr{r9r|rs```` rFrrs!!4 rEc$^^^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$)Nrr})rr)rcrr|r{s rF jump_edge'_add_middleware_edge..jump_edges,IIi(&7$3' '  rErrrFrvN)rcrrr)rlrrr)r`rrr{r|rr destinationss ``` rFrrs*  ,, K     0 k !    ( k !d.?&?    1 2 ##D*:9E*RT`a t01rEr)rVz1ModelResponse | AIMessage | ExtendedModelResponserr%rt)r8r%rbrrr:)rz%Sequence[_ModelCallHandler[ContextT]]rz*_ComposedModelCallHandler[ContextT] | None)rz*Sequence[_AsyncModelCallHandler[ContextT]]rz/_ComposedAsyncModelCallHandler[ContextT] | None)rz set[type]rrrrrr)rrrz list[Any])rzAgentMiddleware[Any, Any]rrrz list[JumpTo])rstr | BaseChatModelrz&list[BaseTool | dict[str, Any]] | Nonerbool)rrrzResponseFormat[Any]rztuple[bool, str])rzSequence[ToolCallWrapper]rzToolCallWrapper | None)rzSequence[Callable[[ToolCallRequest, Callable[[ToolCallRequest], Awaitable[ToolMessage | Command[Any]]]], Awaitable[ToolMessage | Command[Any]]]]rzCallable[[ToolCallRequest, Callable[[ToolCallRequest], Awaitable[ToolMessage | Command[Any]]]], Awaitable[ToolMessage | Command[Any]]] | None)rrrz?Sequence[BaseTool | Callable[..., Any] | dict[str, Any]] | Nonerzstr | SystemMessage | Nonerz.Sequence[AgentMiddleware[StateT_co, ContextT]]rzCResponseFormat[ResponseT] | type[ResponseT] | dict[str, Any] | Nonerz"type[AgentState[ResponseT]] | Nonerztype[ContextT] | NonerzCheckpointer | NonerzBaseStore | Nonerlist[str] | NonerrrrrrrzBaseCache[Any] | NonerzcCompiledStateGraph[AgentState[ResponseT], ContextT, _InputAgentState, _OutputAgentState[ResponseT]])rz JumpTo | Noner{rr|rrr)r[zlist[AnyMessage]rz*tuple[AIMessage | None, list[ToolMessage]])r{rr9!dict[str, OutputToolBinding[Any]]r|rr3Callable[[dict[str, Any]], str | list[Send] | None])r{rr|rrr) rXrr{rr9rr|rrz&Callable[[dict[str, Any]], str | None])r`z[StateGraph[AgentState[ResponseT], ContextT, _InputAgentState, _OutputAgentState[ResponseT]]rrrrr{rr|rrzlist[JumpTo] | NonerNone)prA __future__rr dataclassesrrtypingrrrr r r r r *langchain_core.language_models.chat_modelsrlangchain_core.messagesrrrrlangchain_core.toolsrlanggraph._internal._runnablerlanggraph.constantsrrlanggraph.graph.staterlanggraph.prebuilt.tool_noderrlanggraph.typesrrtyping_extensionsrrr!langchain.agents.middleware.typesrr r!r"r#r$r%r&r'r(r)r*"langchain.agents.structured_outputr+r,r-r.r/r0r1r2r3langchain.chat_modelsr4r6collections.abcrGrHrIlangchain_core.runnablesrJrKlanggraph.cache.baserLrMlanggraph.runtimerNlanggraph.store.baserOrPrQrR_ModelCallHandler_ComposedModelCallHandler_AsyncModelCallHandler_ComposedAsyncModelCallHandlerrstriprFrrYrfrrrrrrrrr rrrrrrr__all__r<rErFr s@"(   EUU):*,F)>>       2  UWY%7 U  U==A.8).,R h <+A*BM*Q!RS !$99 ; !) h <+A*BM*Q!RS& (! & h <+A*BImD\*\!]^-)+.CCD F &. h <+A*BImD\*\!]^01 3&" $P 0 EG14 *&  =  $6:'!'2''TY3Y/YxX8X4Xv3D  HQU% %'M% %P**(**<-'--`== =DNRw15AC[_7;,0(,")-(,#'w w Jw. w ? w Y w5w*w&w w'w&w w w !w !wt       /*::?: : 9 :z9 6!!!? !  ! , !H-2 -2  -2  -2-2-2%-2 -2b rE