"jV%SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKJ r SSK J r J r J r SSKJr SSKJr SSKJr SSKJrJrJrJrJrJrJrJrJr SSKrSSKrSS K J!r!J"r"J#r# SS K$J%r%J&r&J'r' SS K(J)r)J*r*J+r+ S S K,J-r-J.r.J/r/ S SK0J1r1 S SK2J3r3J4r4 SSK5J6r7 SSK8J9r9 SSK:J;r; SSKJ?r? SSK@JArAJBrB SSKCJDrD SSKEJFrFJGrGJHrHJIrI SSKJJKrK SSKLJMrM SSKJJPrP SSKQJRrS \(aSSKTJUrU SSKVJWrW SSKXJWrY OSSKVJWrW SSKXJWrY S SKZJ[r[J\r\J]r]J^r^J_r_ S S K`JaraJbrbJcrcJdrd S S!KeJfrf \a"5rg\#"\h\i\45rj\#"\k\i5rl"S"S#\5rm\ S$\ \m4rnSfS%jroS&rp"S'S(\q5rr\"S)S*S+9"S,S-55rs\"S)S*S+9"S.S/55rt\"S)S*S+9"S0S1\ 55ru\"S)S*S+9"S2S3\u55rv\"S)S*S+9"S4S5\u55rw\"S)S*S+9"S6S755rx\"S)S*S+9"S8S955ry\"S)S*S+9"S:S;55rz\S<r{\"S)S*S+9"S=S>55r|\^R\^R-\x-\|-r\"S)S*S+9"S?S@55r\"S)S*S+9"SASB55r\"S)S*S+9"SCSD55r\GR"\GRGR \GRGR 5\GRGR55SE9r\GR"SF5rSGr\i\^R-\h\i\4-\k\-\ \i\^R-\h\i\4-\k\--r"SHSI\5r\ \*\\\i\h\i\4/\ \4r\7\\F-\W-\Y-\!-\-\i-rSJ\SK'\"5rSL\SM'\"S)S)SN9"SOSP\3\)55rSgSQjrShSRjrSiSSjrSjSTjrSSU.SkSVjjrS)SW.SlSXjjrSmSYjrSnSZjrSoS[jrSpS\jrSqS]jrSrS^jrSsS_jr"S`Sa\&S)Sb9r"ScSd\&5r\#"\5rStSejrg!\NarO\N"S5\OeSrOCOff=f!\Na \rWGNRf=f!\Na \rYGNZf=f)u) annotationsN)ABC) AwaitableCallableSequence)AsyncExitStack) dataclass)Path) TYPE_CHECKING AnnotatedAnyLiteralNoReturnProtocol TypeAliascastoverload)AnyUrlField TypeAdapter)Self TypedDict assert_never) AgentDepsT RunContextToolDefinition)AsyncHTTPClientHTTPAuth HTTPTimeout) model_request)AbstractToolset ToolsetTool)Client)ElicitationHandler) LogHandler)MessageHandlerT)ProgressHandler) RootsHandler RootsList)SamplingHandler)ClientTransport SSETransportStdioTransportStreamableHttpTransport) ToolError)infer_transport_type_from_urluPlease install the fastmcp client to use `MCPToolset` — `pip install "pydantic-ai-slim[mcp]"` pulls `fastmcp-slim[client]`, or install the full `fastmcp` package directly.)McpError)types)CallToolResult)FastMCP)_mcp_utils exceptionsmessagesmodels) is_mcp_sdk_v2 mcp_fieldmcp_optional_fieldmcp_validated_field) ModelSettingsc\rSrSrSSjrSrg) _ToolTaskYc # g7fNselfs L/home/mande/repo/quber/.venv/lib/python3.13/site-packages/pydantic_ai/mcp.pyresult_ToolTask.resultZscrEN)returnr4)__name__ __module__ __qualname____firstlineno__rI__static_attributes__rErHrArAYs1rRrA.c`SSKn[[UR5$![a gf=f)zBLoad FastMCP's task extension when an `MCPToolset` is constructed.rN) fastmcp_tasks ImportErrorr _CallToolTaskcall_tool_task)rTs rH_load_call_tool_taskrX`s3  };; << s  --) MCPToolsetMCPToolsetClientload_mcp_toolsetsMCPErrorResourceResourceAnnotationsResourceTemplateServerCapabilitiesProcessToolCallback CallToolFunc ToolResultPromptPromptArgument PromptMessage PromptResultIcon ResourceLinkEmbeddedResource ContentBlock PromptRolecx^\rSrSr%SrS\S'S\S'S\S'S SU4S jjjr\SS j5rSS jr S r U=r $)r\zRaised when an MCP server returns an error response. This exception wraps error responses from MCP servers, following the ErrorData schema from the MCP specification. strmessageintcodedict[str, Any] | NonedatacH>XlX lX0l[TU]U5 grD)rprrrtsuper__init__)rGrprrrt __class__s rHrwMCPError.__init__s    !rRcfURnU"URURURS9$)z]Create an MCPError from an MCP SDK McpError. Args: error: An McpError from the MCP SDK. )rprrrt)errorrprrrt)clsr{ error_datas rH from_mcp_sdkMCPError.from_mcp_sdks*[[ :--JOO*//ZZrRcUR(a)URSURSURS3$URSURS3$)Nz (code: z, data: ))rtrprrrFs rH__str__MCPError.__str__sI 99ll^8DII;htyykK K,,x {!44rR)rrrtrprD)rprorrrqrtrs)r{r2rLr\rLro) rMrNrOrP__doc____annotations__rw classmethodr~rrQ __classcell__rxs@rHr\r\sM L I0 L"" [[55rRr\FT)reprkw_onlycv\rSrSr%SrSrS\S'SrS\S'SrS\S '\ Rr \ S S j5r S rg) r^zAdditional properties describing MCP entities. See the [resource annotations in the MCP specification](https://modelcontextprotocol.io/specification/2025-11-25/server/resources#annotations). Nzlist[mcp_types.Role] | Noneaudiencez.Annotated[float, Field(ge=0.0, le=1.0)] | Nonepriority str | None last_modifiedc XU"URUR[US[5S9$)zuConvert from MCP SDK Annotations to ResourceAnnotations. Args: mcp_annotations: The MCP SDK annotations object. r)rrr)rrr=ro)r|mcp_annotationss rHr~ ResourceAnnotations.from_mcp_sdks1$--$---_osS   rRrE)rzmcp_types.AnnotationsrLr^)rMrNrOrPrrrrrr7dataclasses_no_defaults_repr__repr__rr~rQrErRrHr^r^sO -1H)0,?CH<CB $M:$622H    rRr^c^\rSrSr%SrS\S'SrS\S'SrS\S '\Rr S r g) rhz'An icon for display in user interfaces.rosrcNr mime_typelist[str] | NonesizesrE) rMrNrOrPrrrrr7rrrQrErRrHrhrhs31 H' Iz *"E "Y22HrRrhc\rSrSr%SrS\S'SrS\S'SrS\S'SrS\S 'Sr S \S 'Sr S \S 'Sr S\S'\ RrSrg) BaseResourcezBase class for MCP resources.ronameNrtitle descriptionrResourceAnnotations | Nonerlist[Icon] | NoneiconsrsmetadatarE)rMrNrOrPrrrrrrrrr7rrrQrErRrHrrsi' I0E:/"K"9 Iz 2.2K+20#E #*&*H#*-22HrRrcJ\rSrSr%SrS\S'SrS\S'\S Sj5rS r g) r]zA resource that can be read from an MCP server. See the [resources in the MCP specification](https://modelcontextprotocol.io/specification/2025-11-25/server/resources). rouriN int | NonesizecU"[UR5URURUR[ US[5UR UR(a[RUR5OSUR(aIURVs/sH1n[UR[ US[5URS9PM3 snOSURS9 $s snf)zlConvert from MCP SDK Resource to PydanticAI Resource. Args: mcp_resource: The MCP SDK Resource object. rNrrr) rrrrrrrrrrorrrrr=rrr^r~rrhrrmeta)r| mcp_resourceicons rHr~Resource.from_mcp_sdksL$$%""$$$00({CH""'',889Q9QR!!)..  /D 0{CH** / !&&)  s#8C-rE)rzmcp_types.ResourcerLr]) rMrNrOrPrrrrr~rQrErRrHr]r]s0 H"D*[  rRr]c:\rSrSr%SrS\S'\SSj5rSrg) r_i"zA template for parameterized resources on an MCP server. See the [resource templates in the MCP specification](https://modelcontextprotocol.io/specification/2025-11-25/server/resources#resource-templates). ro uri_templatecU"[US[5URURUR[ US[5UR (a[RUR 5OSUR(aIURVs/sH1n[UR[ US[5URS9PM3 snOSURS9$s snf)zConvert from MCP SDK ResourceTemplate to PydanticAI ResourceTemplate. Args: mcp_template: The MCP SDK ResourceTemplate object. rrNr)rrrrrrrr)r<rorrrr=rr^r~rrhrrr)r| mcp_templaters rHr~ResourceTemplate.from_mcp_sdk,s"<E""$$$00({CH'',889Q9QR!!)..  /D 0{CH** / !&&'  s8CrEN)rzmcp_types.ResourceTemplaterLr_) rMrNrOrPrrrr~rQrErRrHr_r_"s$ A  rRr_c\rSrSr%SrS\S'S\S'SrS\S'SrS\S 'SrS\S 'Sr S \S 'Sr S \S'Sr S\S'Sr S\S'Sr S\S'\Rr\SSj5rSrg)riiJuA resource link referenced in a prompt or tool call result. Unlike [`EmbeddedResource`][pydantic_ai.mcp.EmbeddedResource], this does not include the resource content directly — it is a reference to a resource that the server can read. Note: resource links returned by tools are not guaranteed to appear in the results of `resources/list` requests. See the [MCP specification](https://modelcontextprotocol.io/specification/2025-11-25/server/resources). rorrNrrrrrrrrrrrsr resource_linkzLiteral['resource_link']typecU"S[UR5URURUR[ US[5UR UR(a[RUR5OSUR(aIURVs/sH1n[UR[ US[5URS9PM3 snOSURS9 $s snf)z=Convert from MCP SDK ResourceLink to PydanticAI ResourceLink.rrNr) rrrrrrrrrrr)r|mcp_resource_linkrs rHr~ResourceLink.from_mcp_sdkws %))*"''#)))55():KM"'' ,,,889J9V9VW!&&.33  4D 0{CH** 4 &+++  s$8C.rE)rzmcp_types.ResourceLinkrLri)rMrNrOrPrrrrrrrrrrr7rrrr~rQrErRrHririJs  H) I7E:/"K"@ Iz 9D*[.2K+27#E #1&*H#*4%4D "4222H  rRricn\rSrSr%SrS\S'SrS\S'SrS\S'SrS \S '\ Rr S r g) reiz"An argument for a prompt template.rorNrrr bool | NonerequiredrE) rMrNrOrPrrrrrr7rrrQrErRrHreres?, I#E:0"K"7 Hk y22HrRrec\rSrSr%SrS\S'SrS\S'SrS\S'SrS \S 'Sr S \S 'Sr S \S'\ Rr \SSj5rSrg)rdiz3A prompt or prompt template that the server offers.rorNrrrzlist[PromptArgument] | None argumentsrrrsrcU"URURURUR(aPURVs/sH8n[ UR[ USS5URUR S9PM: snOSUR(aIURVs/sH1n[UR[US[5URS9PM3 snOSURS9$s snfs snf)zdConvert from MCP SDK Prompt to PydanticAI Prompt. Args: mcp_prompt: The MCP SDK Prompt object. rN)rrrrrr)rrrrrr)rrrrregetattrrrrhrr=rorr)r| mcp_promptargrs rHr~Prompt.from_mcp_sdks"""..##&// 0C"#w5 # \\ 0 ',,  -D 0{CH** - __7   s ?C/%8C4rE)rzmcp_types.PromptrLrd)rMrNrOrPrrrrrrrr7rrrr~rQrErRrHrdrdsr= I.E:*"K"?-1I*1?#E #4&*H#* 22H" " rRrd)user assistantc\rSrSr%SrS\S'S\S'SrS\S 'S rS \S 'S rS \S'S r S\S'S r S\S'\ Rr \SSj5rSrg )rjia/A resource embedded into a prompt or tool call result. Contains the actual resource content alongside its metadata, unlike [`ResourceLink`][pydantic_ai.mcp.ResourceLink] which is only a reference. See the [MCP specification](https://modelcontextprotocol.io/specification/2025-11-25/server/resources). rorstr | messages.BinaryContentcontentresourcezLiteral['resource']rNrrrrrsrresource_metadatac  U"[URR5U[URS[5UR(a[ R UR5OSURURRS9$)zEConvert from MCP SDK EmbeddedResource to PydanticAI EmbeddedResource.rN)rrrrrr)rorrr=rr^r~r)r|partrs rHr~EmbeddedResource.from_mcp_sdksjDMM%%&( SINRN^N^+889I9IJdhYY"mm00   rRrE)rzmcp_types.EmbeddedResourcerrrLrj)rMrNrOrPrrrrrrrr7rrrr~rQrErRrHrjrjs H+ ))/ *D *6 Iz 2.2K+20&*H#* 04,3f22H    rRrjcJ\rSrSr%SrS\S'S\S'\RrSr g) rfiz.A message returned as part of a prompt result.rlrolerkrrEN) rMrNrOrPrrr7rrrQrErRrHrfrfs"8 ) %22HrRrfc^\rSrSr%SrS\S'SrS\S'SrS\S '\Rr S r g) rgi,zNThe result of a [`get_prompt`][pydantic_ai.mcp.MCPToolset.get_prompt] request.zlist[PromptMessage]r9NrrrsrrE) rMrNrOrPrrrrr7rrrQrErRrHrgrg,s8X!!"K"1&*H#* 22HrRrgc\rSrSr%SrSrS\S'SrS\S'SrS\S 'Sr S\S 'Sr S\S 'Sr S\S 'Sr S\S 'Sr S\S'SrS\S'\R r\SSj5rSrg)r`i?z)Capabilities that an MCP server supports.Nr experimentalFboolloggingpromptsprompts_list_changed resourcesresources_list_changedtoolstools_list_changed completionscURnURnURnU"UR(a#[ URR 55OSUR SLUSLU(a[[US[55OSUSLU(a[[US[55OSUSLU(a[[US[55OSURSLS9 $)zConvert from MCP SDK ServerCapabilities to PydanticAI ServerCapabilities. Args: mcp_capabilities: The MCP SDK ServerCapabilities object. N list_changedF) rrrrrrrrr) rrrrlistkeysrrr=r)r|mcp_capabilities prompts_cap resources_cap tools_caps rHr~ServerCapabilities.from_mcp_sdk`s'.. (22 $** GWGdGd.;;@@BCjn$,,D8t+`k&8nVZ&[!\qv#4/$((:=.Z^(_#`4'\et$6y.RV$WXkp(44D@  rRrE)rzmcp_types.ServerCapabilitiesrLr`)rMrNrOrPrrrrrrrrrrrr7rrrr~rQrErRrHr`r`?s3%)L")KGTIGT9!&$&VIt:#(D(XE46$$TKY22H  rRr`)schemaz\$\{([^}:]+)(:-([^}]*))?\}c8\rSrSrSrSS.SSjjrSrg)rbiu=A callable that invokes an MCP tool — typically `MCPToolset.direct_call_tool` or its legacy equivalent. Passed to user-defined [`ProcessToolCallback`][pydantic_ai.mcp.ProcessToolCallback] functions as the underlying call hook. `metadata` is keyword-only — pass it as `await call_tool(name, args, metadata=...)`. N)rc # g7frDrE)rGrargsrs rH__call__CallToolFunc.__call__s rKrE)rrordict[str, Any]rrsrLrc)rMrNrOrPrrrQrErRrHrbrbs<+/  (   rRrbrrZr _UNSET)initrc,^\rSrSr%SrS\S'S\S'S\S'S \S 'S \S 'S \S 'S \S 'S \S'S\S'S\S'S\S'S\S'S\S'S\S'S\S'S\S'S\S'S \S!'S"\S#'S$\S%'S&\S''S(\S)'S*\S+'S,\S-'\RSXS.j5rS/S/S0S/S1S1S1S1S2S/S/S/S/S/S/S/S/S/\ \ S/S/S/S/S/S3.SYS4jjr \ SZS5j5r \ RS[S6j5r \ S\U4S7jj5r\ S\S8j5r\ S]S9j5r\ S^S:j5r\ SZS;j5r\ S_S<j5rS`S=jr\ S_S>j5rSaS?jrSaS@jrSaSAjrSbSBjrScSCjrSdSDjrSeSEjrSfSFjrSgSGjrSgSHjrShSIjr S/S2SJ.SiSKjjr!SjSLjr"SkSMjr#SlSmSNjjr$SnSOjr%SoSPjr&\'SpSQj5r(\'SqSRj5r(SrSSjr(S\STjr)SsSUjr*StSVjr+SWr,U=r-$)urYiuA toolset for connecting to an MCP server. `MCPToolset` is the recommended way to use [Model Context Protocol](https://modelcontextprotocol.io) servers in Pydantic AI. It is built on the [FastMCP](https://gofastmcp.com) `Client`, which supports the full MCP protocol — tools, resources, sampling, elicitation, OAuth — and a wide range of transports (HTTP, SSE, stdio, in-process FastMCP servers, multi-server configs). Pass any input that FastMCP can build a transport from — a URL, a script path, a `FastMCP` server instance for in-process testing — or a pre-built `fastmcp.Client` for full control over its configuration. For multi-server JSON config files, use [`load_mcp_toolsets`][pydantic_ai.mcp.load_mcp_toolsets] instead. Example — connect to a streamable-HTTP MCP server: ```python {test="skip"} from pydantic_ai import Agent from pydantic_ai.mcp import MCPToolset toolset = MCPToolset('http://localhost:8000/mcp') agent = Agent('openai:gpt-5', toolsets=[toolset]) ``` Example — connect to a local stdio MCP server: ```python {test="skip"} from pydantic_ai.mcp import MCPToolset toolset = MCPToolset('my_mcp_server.py') ``` Example — pass a pre-built FastMCP Client for full configuration control: ```python {test="skip"} from fastmcp.client import Client from fastmcp.client.transports import StreamableHttpTransport from pydantic_ai.mcp import MCPToolset client = Client(StreamableHttpTransport('http://localhost:8000/mcp'), auth='oauth') toolset = MCPToolset(client) ``` zFastMCPClient[Any]client#Literal['retry', 'error', 'failed']tool_error_behaviorr max_retriesr prefer_tasks cache_toolscache_resources cache_promptsinclude_instructionsrinclude_return_schemaProcessToolCallback | Noneprocess_tool_callmodels.Model | Nonesampling_modelmcp_types.LoggingLevel | None log_levelr_idmcp_types.Implementation | None _server_infozServerCapabilities | None_server_capabilities _instructionszlist[mcp_types.Tool] | None _cached_toolszlist[Resource] | None_cached_resourceszlist[Prompt] | None_cached_promptsrq_running_countzAsyncExitStack | None _exit_stackMessageHandlerT | None_user_message_handler_CallToolTask | None_call_tool_taskz list[str]_server_initiated_handlersc,[R"5$rD)anyioLockrFs rH _enter_lockMCPToolset._enter_lock_szz|rRNretryTF)idrrrrrrrrrrsampling_handlerelicitation_handler log_handlerrprogress_handlermessage_handler client_info init_timeout read_timeoutrootsauthverifyheaders http_clientc t[(a [5OSUl/Ul[ U[ 5(aU U UUUUUUUUUUS. nUR 5VVs/sH unnUcM UPM nnnU[LaURS5 U[LaURS5 U(a'SRSU55n[SUS35eXl SUl OU bU b [S 5eUbUb [S 5eU[LaS nU[LaS n[UUUUUUS 9n U n!U!cU b [U 5n![UU5n"[ [ "U U!UUUU"UUUUS9 Ul UUl U!b$URRU (aSOS5 UbURRS5 X lX0lX@lXPlX`lXplXlXlXlXlXlUUlSUlSUlSUlSUl SUl!SUl"SUl#SUl$gs snnf)u{Build a new `MCPToolset`. Args: client: How to connect to the MCP server. See the class docstring for accepted shapes. id: An optional unique identifier for this toolset. Required for use in durable execution environments like Temporal or DBOS, where it identifies the toolset's activities/steps within a workflow. max_retries: Maximum number of times a tool call may be retried after a `ModelRetry`. `None` inherits the agent's retry count at runtime. tool_error_behavior: `'retry'` (default) raises [`ModelRetry`][pydantic_ai.exceptions.ModelRetry] on tool errors so the model can self-correct; `'error'` propagates the underlying exception; `'failed'` raises [`ToolFailed`][pydantic_ai.exceptions.ToolFailed] so the model can see the error. process_tool_call: Hook to wrap tool calls. See [`ProcessToolCallback`][pydantic_ai.mcp.ProcessToolCallback]. prefer_tasks: Whether to prefer task-augmented execution (SEP-1686) for tools that support it optionally. Tools that require task-augmented execution always use it, while tools that forbid it never do. cache_tools: Whether to cache the list of tools. See [`MCPToolset.cache_tools`][pydantic_ai.mcp.MCPToolset.cache_tools]. cache_resources: Whether to cache the list of resources. See [`MCPToolset.cache_resources`][pydantic_ai.mcp.MCPToolset.cache_resources]. cache_prompts: Whether to cache the list of prompts. See [`MCPToolset.cache_prompts`][pydantic_ai.mcp.MCPToolset.cache_prompts]. include_instructions: Whether to include the server's instructions in the agent's instructions. See [`MCPToolset.include_instructions`][pydantic_ai.mcp.MCPToolset.include_instructions]. include_return_schema: Whether to include return schemas in tool definitions. See [`MCPToolset.include_return_schema`][pydantic_ai.mcp.MCPToolset.include_return_schema]. sampling_model: A Pydantic AI model the server may sample from. Mutually exclusive with `sampling_handler`. sampling_handler: A FastMCP-shaped sampling handler. Use for full control over the sampling response. elicitation_handler: A FastMCP-shaped elicitation handler that receives MCP `elicitation/create` requests from the server. log_handler: A FastMCP-shaped log handler that receives log messages from the server. log_level: Log level requested via `logging/setLevel` after initialization. A modern MCP session warns and skips it because the method is handshake-era only, and expects the client to filter in `log_handler`; legacy sessions remain supported despite the upstream deprecation. progress_handler: A FastMCP-shaped progress handler. message_handler: A FastMCP-shaped message handler called for every server-sent message. Pydantic AI installs its own message handler internally to invalidate caches on `list_changed` notifications; if you provide one, both run (yours after ours). client_info: Information describing the MCP client implementation, sent to the server during initialization. init_timeout: Timeout in seconds for the initial connection and `initialize` handshake. read_timeout: Maximum time in seconds to wait for new messages on the long-lived connection. Defaults to 5 minutes. roots: Filesystem roots advertised to the server. auth: HTTP authentication for HTTP transports — an `httpx2.Auth` (a legacy `httpx.Auth` when the installed fastmcp is 3), the literal string `'oauth'` to enable FastMCP's OAuth flow, or a bearer-token string. verify: SSL verification mode for HTTP transports — an `ssl.SSLContext`, a CA bundle path string, or a bool. headers: Extra HTTP headers for HTTP transports. Mutually exclusive with `http_client`. http_client: A pre-configured `httpx2.AsyncClient` (a legacy `httpx.AsyncClient` when the installed fastmcp is 3) to use for HTTP transports — useful for self-signed certificates or custom connection pooling. Mutually exclusive with `headers`. Raises: ValueError: If a pre-built `fastmcp.Client` is passed alongside any of the kwargs that would otherwise build a default Client (sampling, elicitation, headers, etc.), or if `sampling_model` and `sampling_handler` are both passed, or if `headers` and `http_client` are both passed. N) rrrrrrrr"r#r$r%r&r r!, c38# UHn[U5v M g7frD)r).0ns rH &MCPToolset.__init__..s!=9a$q''9sz Cannot pass uY alongside a pre-built `fastmcp.Client` — configure these on the Client itself instead.z=Pass either `sampling_model` or `sampling_handler`, not both.u``headers` and `http_client` are mutually exclusive — set headers on the `http_client` instead.,)r%r&r#r$r!) transportrrrrrrr timeoutr"rrrr)% _MCP_SDK_V2rXrr isinstance FastMCPClientitemsrappendjoin ValueErrorrr_build_transport_build_sampling_handler_build_message_handlerr rrrrrrrrrrrrrrrr r r r r )#rGrrrrrrrrrrrrrrrrrrrr r!r"r#r$r%r&forwarded_valuesrvalue conflictsnamesr0resolved_sampling_handlerwrapped_message_handlers# rHrwMCPToolset.__init__esN:E35$ +-' fm , ,$4"0':*$4#2* "* 0 2B1G1G1I_1I+$U1II_6)  06)  0 !=9!== "5'*DD!K)-D &+0J !`aa"{'> v v% v%% (') I)9 %(0^5O,CN,S)&7G_qr".//667LM&#6 !2(&.*$8!%:"," $(!!!!%#c`s  H4)H4cUR$rDrrFs rHr MCPToolset.id4s xxrRcXlgrDrDrGr=s rHrrE8srRcP>UR(a [TU]$[U5$rD)rrvlabelr)rGrxs rHrIMCPToolset.label<s 777= DzrRcg)Nz^Wrap the toolset with `.prefixed("...")` to disambiguate tool names from multiple MCP servers.rErFs rHtool_name_conflict_hint"MCPToolset.tool_name_conflict_hintBsorRcURcWUR(a#[SURRS35e[SURRS35eUR$)zThe server's implementation info, when the server provided it. Raises [`AttributeError`][AttributeError] when accessed before the toolset has been entered, or when a modern MCP session's server omitted the optional `serverInfo` stamp. `zK.server_info` is unavailable: this server did not send implementation info.z5.server_info` is only available after initialization.)r _initializedAttributeErrorrxrMrFs rH server_infoMCPToolset.server_infoFsp    $  $//01++!1T^^%<%<$==r!st t   rRczURc#[SURRS35eUR$)zThe capabilities advertised by the server during initialization. Raises [`AttributeError`][AttributeError] when accessed before the toolset has been entered. rOz6.capabilities` is only available after initialization.)rrQrxrMrFs rH capabilitiesMCPToolset.capabilitiesVs<  $ $ , 1T^^%<%<$==s!tu u(((rRcUR(d#[SURRS35eUR$)zThe instructions sent by the server during initialization. Raises [`AttributeError`][AttributeError] when accessed before the toolset has been entered. rOz6.instructions` is only available after initialization.)rPrQrxrMrrFs rH instructionsMCPToolset.instructions`s9    1T^^%<%<$==s!tu u!!!rRc URS:$)zGWhether the toolset is currently entered (the FastMCP session is open).r)r rFs rH is_runningMCPToolset.is_runningjs""Q&&rRcXlURnSU;aSX"RS5'OSU;aURS5 URR [ U55 g)aYSet the [`sampling_model`][pydantic_ai.mcp.MCPToolset.sampling_model] on an already-constructed toolset. Swaps both the public attribute and the underlying FastMCP client's sampling callback. Takes effect on the next session opened by the client; calls already in flight on an existing session continue using the previously configured handler. rrN)rrindexr6rset_sampling_callbackr:)rGmodelhandlerss rHset_sampling_modelMCPToolset.set_sampling_modelos^$22  );KH^^$67 8 X - OO, - ))*A%*HIrRcURSL$rD)rrFs rHrPMCPToolset._initializeds((44rRcSUlgrD)r rFs rH_invalidate_tools_cache"MCPToolset._invalidate_tools_caches !rRcSUlgrD)r rFs rH_invalidate_resources_cache&MCPToolset._invalidate_resources_caches !%rRcSUlgrD)r rFs rH_invalidate_prompts_cache$MCPToolset._invalidate_prompts_caches #rRc (# URIShvN URS:XGa[5IShvN nURUR5IShvN URR nUc[ (d[R"S5e[URSS5n[URSS5n[URSS5n[U[R5(d[R"S5e[U[R5(aUOSn[U[5(aUOSnO3[US[R5nUR nUR"n[R%U5nUSLn UR&(aU (azUR&V s/sHn U S:wdUR(bMU PM n n U (aBSR+S U 55n [,R."U S UR0S 3[2S S 9 UR4bU (a)[,R."SUR0S3[2S S 9 Oo[,R6"5 [,R8"SS[:S9 URR<R?UR45IShvN SSS5 URA5Ul!X`l"Xl#Xpl$SSS5IShvN U=RS- slSSS5IShvN U$GN%GNGNs sn fNx!,(df  N|=fNL!,IShvN (df  Na=fNC!,IShvN (df  U$=f7f)NruThe FastMCP client connected but never initialized — was it built with `auto_initialize=False`? `MCPToolset` needs an initialized client.rRserver_capabilitiesrXaThis client opened without an `initialize` handshake and exposes no `server_capabilities` to read server metadata from. If the client was built with `auto_initialize=False`, remove that; otherwise upgrade `fastmcp` to a version that provides era-neutral server metadata.rr(c3.# UH nSUS3v M g7f)rONrE)r*rs rHr,(MCPToolset.__aenter__..s-Tmd$qkmsz will never be called: zz negotiated a modern MCP session, which holds no connection for the server to issue sampling or elicitation requests over.) stacklevelz`log_level` was not applied: u negotiated a modern MCP session, and the modern MCP protocol has no `logging/setLevel` request — the server sends every level and leaves filtering to the client. Filter by level in `log_handler` instead.ignorez&The logging capability is deprecated.*)rpcategoryr)%rr renter_async_contextrinitialize_resultr2r8 UserErrorrr3 mcp_typesr`Implementationror<rUrXr~rrr7warningswarnrI UserWarningrcatch_warningsfilterwarningsWarningsessionset_logging_levelpop_allr rrr) rG exit_stack init_resultraw_server_inforUraw_instructionsrRrXrpmodern_sessionr dead_handlersr?s rH __aenter__MCPToolset.__aenter__s ###""a' *++z$88EEE#'++"?"?K"**{#-"6"6!j#+2$++}d*S'.t{{ )-(G(G)(G#'<<@T@T!(G&) )$(II-Tm-T$TE$MM#(')@ M1!1!,+, ~~1)$MM"? |L9!9!,+, "*!8!8!: ( 7 7$,,T-4!" '+kk&9&9&K&KDNN&[ [ [ ";(2'9'9';D$(3%0C-)5&[,+\   1 $ k$#l m$,ER)>!\ ";!:G,+++$##l sNL8N M7L;M7ML>E'MMM#BMA M M M/M M7 M M7& N1M52N;M7>MMM M MM7M2 !M$" M2 .M75N7N=N > N Nc# URIShvN URS:Xa#[SURRS35eU=RS-slURS:Xa`UR bSUR R 5IShvN SUlSUlSUlSUl SUl SUl SUl SSS5IShvN gNNHN !,IShvN (df  g=f7f)NrrOz/.__aexit__` called more times than `__aenter__`r) rr r8rxrMr acloserrrr r r )rGrs rH __aexit__MCPToolset.__aexit__s###""a' 1T^^%<%<$==l!mnn   1 $ ""a'D,<,<,H&&--///#' $(!,0)%)"%)")-&'+$$#$ 0 $##sWDC!DBC'C#5C' DC%D#C'%D'C>-C0 . C>:Dc# UR(dgUR(a URcg[R"URSS9$7f)zFReturn the server's instructions if `include_instructions` is enabled.NF)rdynamic)rrPrr9InstructionPart)rGctxs rHget_instructionsMCPToolset.get_instructionssC((  D$6$6$>''0B0BERRsAAcL# UR(aURb UR$UIShvN URR5IShvN nUR(aXlUsSSS5IShvN $NPN0N !,IShvN (df  g=f7f)zRetrieve the tools currently exposed by the server. When [`cache_tools`][pydantic_ai.mcp.MCPToolset.cache_tools] is enabled (default), results are cached and invalidated by `notifications/tools/list_changed` or the toolset's last `__aexit__`. N)rr r list_tools)rGrs rHrMCPToolset.list_toolssj    2 2 >%% %4++0022E%*" 442444sV1B$BB$B BB 2 B$>B?B$B B$ B!B  B!B$c # UR5IShvN n0nUGHnUR(a[URS[5OSn[ US[ 5nUcS5e[ US[ 5nUR [URURUURUR(aURRSS9OS[(+=(a$ US:H=(d US:H=(a URS .U=(d SURS 9US 9X4R'GM U$GN)7f) N task_support input_schemaz&MCP tools always carry an input schema output_schemaT)by_aliasroptional)rrtask)rrparameters_json_schemar return_schemarr)r executionr=ror>_JSON_SCHEMA_ADAPTERtool_for_tool_defrrrrr model_dumpr2rr)rGr mcp_toolsrmcp_toolrrrs rH get_toolsMCPToolset.get_toolss-//++ 46!HZbZlZl-h.@.@.RUVrvL.xI]^L+ U-U U+//K_`M#'#9#9! ( 4 4+7 ( ZbYmYmx';';'F'FPT'F'Usw%0!o)Z7mLJCC#C$C%C<C=CCC)ruse_taskc"# UIShvN U(aURXU5IShvN nO2URRUUUURS:HS9IShvN nSSS5IShvN [WURS9nUR(akURcUR (dS U<S 3nO/["R$"XS 9R'S S 9nU(dS U<S 3n[ UUR5 U$NNN![a9nURS:Xae[ [ U5URUS9 SnANSnAf[a0nURS:Xae[ [ U5SUS9 SnAGNSnAf[RanURS:XaeUR[[45upUbU beUn URn U S:XaUR[5upU bU n Sn U n[U[R5(a0URSn[U[R5(aM0[ [ U5XS9 SnAGNSnAff=fGN!,IShvN (df  GN=f7f)a*Call a tool on the server directly. Args: name: The name of the tool to call. args: The arguments to pass to the tool. metadata: Optional request-level `_meta` payload sent alongside the call. use_task: When `True`, ask the server to run the call as a durable, cancelable, pollable task. FastMCP 3 uses the MCP SEP-1686 `task=True` call path, while FastMCP 4 uses its tasks extension (SEP-2663). Only valid for tools that support task execution. Both paths wait for and return the completed tool result; on FastMCP 4, `use_task=True` explicitly selects the tasks extension even though an ordinary call can also drive a task-only tool to completion. Raises: ModelRetry: If a completed tool error occurs with `tool_error_behavior='retry'` (the default), or if a protocol-level `McpError` occurs and `tool_error_behavior` is not `'error'`. fastmcp.exceptions.ToolError or the MCP SDK's McpError: If an error occurs and `tool_error_behavior='error'`. ToolFailed: If a completed tool error occurs and `tool_error_behavior='failed'`. UserError: If `use_task=True` and the FastMCP 4 client negotiated a legacy protocol session, which has no task path. ImportError: If `use_task=True` on FastMCP 4 and `fastmcp-tasks` is not installed. Nr{rcauserfailedrprefer_structuredzTool z returned an error) tool_namerF) wrap_if_error)rrrrr0_raise_mcp_tool_errorror2r7BaseExceptionGroupsplitr3r8_map_mcp_call_tool_resultis_errorstructured_contentrr9ToolReturnPartmodel_response_str)rGrrrrrIeegmatchedrest error_groupbehaviorprotocol_errors_r{ mapped_resultrps rHdirect_call_toolMCPToolset.direct_call_tool^sF<42 F#'#:#:4x#PPF#';;#8#8!"&%'+'?'?7'J $9$F 4j2&FOO\ ??((0!$);<"11DXkk"'l %dX-?@G !'4+C+C DCQ  Q++w6%c!fd.F.FaP @ ++w6%c!fgQ??,, F++w6 ")X)> ? ?d&6& 33x')0x)@&O&2&5 #*(3 (A(ABB!,,Q/E!(A(ABB%c%j(EE7 F1444sJDJI4D DD I4,D D D "I4# J.I1/BJD  D  I./E I4 I.%F;I4I.B6I)I)#I4)I..I41J4J :I= ; J Jc:# [URR=(d 0RS55nURb8UR U[ R "URUS9X5IShvN $URXUS9IShvN $NN7f)Nr)r)rrrgetr functoolspartialr)rGr tool_argsrtoolrs rHrMCPToolset.call_tools//52::6BC  ! ! -//Y&&t'<'> 8CC{!v**1-{GC!!'.$44? 6++A.A5 6C4441D'CD'D  D' C!D''CCC D  D,D  D'D D'D'C D(C>>DD  D' D$D  D$ D'c6# UIShvN URR(d[SU<S3SS9eURR X5IShvN n[URURURVs/sH*n[UR[UR5S9PM, snS9sSSS5IShvN $NNv![ an[R U5UeSnAff=fs snfN6!,IShvN (df  g=f7f)a<Retrieve a specific prompt from the server, optionally parameterized. Args: name: The name of the prompt to retrieve. arguments: Arguments to parameterize the prompt, if applicable. Raises: MCPError: If the server doesn't advertise the `prompts` capability, or if it returns an error response. NzFServer does not advertise the `prompts` capability; cannot get prompt .i)rprr)rr)rrr9)rUrr\r get_promptr2r~rgrrr9rfr_map_mcp_prompt_partr)rGrrrIrmsgs rHrMCPToolset.get_prompts4$$,,deidllmn 6#{{55dFF "..gmgvgvgv`cMsxx9Mckk9Z[gv44G 6++A.A5 6 444sDC D+C?CCC)C?1C86C?: DC=DC C5C00C55C?=D?DD  DDcR# UR(aURb UR$UIShvN URR(d/sSSS5IShvN $URR 5IShvN nUVs/sHn[RU5PM nnUR(aX@lUsSSS5IShvN $NNyNW![ an[RU5UeSnAff=fs snfN8!,IShvN (df  g=f7f)aRetrieve the resources currently exposed by the server. When [`cache_resources`][pydantic_ai.mcp.MCPToolset.cache_resources] is enabled (default), results are cached and invalidated by `notifications/resources/list_changed` or the toolset's last `__aexit__`. Returns an empty list if the server does not advertise the `resources` capability. Raises: MCPError: If the server returns an error. N) rr rUrrlist_resourcesr2r\r~r])rG mcp_resourcesrrrs rHrMCPToolset.list_resourcess   D$:$:$F)) )4$$..44 6&*kk&@&@&B B ![an[ R U5UeSnAff=fNX!,IShvN (df  Nm=fs snf7f)zRetrieve the resource templates currently exposed by the server. Returns an empty list if the server does not advertise the `resources` capability. Raises: MCPError: If the server returns an error. N)rUrrlist_resource_templatesr2r\r~r_)rG mcp_templatesrts rHr"MCPToolset.list_resource_templates s4$$..44 6&*kk&I&I&K K 4;HH-Q --a0-HH!L 6++A.A5 6 444IsC$BC$C C$BC$BBB C$*C+C$3CC$C$B C%B;;CCC$C C C C$c # g7frDrErGrs rH read_resourceMCPToolset.read_resource1srurKc # g7frDrErs rHrr4s MPrKc# [U[5(aUO URnUIShvN URR [ U55IShvN nSSS5IShvN [W5S:Xa[US5$UVs/sHn[U5PM sn$NzNO![ an[RU5UeSnAff=fNi!,IShvN (df  N~=fs snf7f)uRead the contents of a specific resource by URI. Args: uri: The URI of the resource to read, or a [`Resource`][pydantic_ai.mcp.Resource] object. Returns: The resource contents — a single value if the resource has one content item, or a list otherwise. Text content is returned as `str`, binary content as [`BinaryContent`][pydantic_ai.messages.BinaryContent]. Raises: MCPError: If the server returns an error. Nrr) r3rorrrrr2r\r~len_resource_content_to_pai)rGr resource_uricontentsrcs rHrr9s )c22s 4 6!%!:!:6,;O!PP48}! %Xa[ 1 8@@x!*1-x@ P 6++A.A5 6444As*C4B'C4C'B+B)B+ C4)C*%C4C/$C4)B++ C5C  CCC4C,C  C,( C4cSUR<3/nURbURSUR<35 URRSSR U5S3$)Nzclient=zid=(r(r)rrr6rxrMr7)rG repr_argss rHrMCPToolset.__repr__Vs`t{{o./ 88    s488,/ 0..))*!DIIi,@+ACCrRc[U[5=(a8 URUR:H=(a URURL$rD)r3rYrrrGs rH__eq__MCPToolset.__eq__\s6%,fUYY1Ff4;;Z_ZfZfKffrRcV[UR[UR545$rD)hashrrrrFs rH__hash__MCPToolset.__hash___sTXXr$++/00rR)r r r rr rrr rrrrrrrrrrrrrrrr)rLz anyio.Lock)4rrZrrrrrrrrrrrrrrrrrrrrrrrz SamplingHandler[Any, Any] | Nonerz#ElicitationHandler[Any, Any] | NonerzLogHandler | NonerrrzProgressHandler | Nonerrrrr  float | Noner!r r"z$RootsList | RootsHandler[Any] | Noner#(HTTPAuth | Literal['oauth'] | str | Noner$"ssl.SSLContext | bool | str | Noner%dict[str, str] | Noner&AsyncHTTPClient | None)rLr)r=rrLNoner)rLzmcp_types.Implementation)rLr`)rLr)r` models.ModelrLr)rLr)rLr)rr rLr)rRunContext[AgentDepsT]rLzmessages.InstructionPart | None)rLzlist[mcp_types.Tool])rrrLz"dict[str, ToolsetTool[AgentDepsT]])rrrrrLzToolsetTool[AgentDepsT])rrorrrrsrLr4) rrorrrrsrrrLr ) rrorrrzRunContext[Any]rzToolsetTool[Any]rLr )rLz list[Prompt]rD)rrorrrLrg)rLzlist[Resource])rLzlist[ResourceTemplate])rrorLAstr | messages.BinaryContent | list[str | messages.BinaryContent])rr]rLr)rzstr | ResourcerLr)r=objectrLr)rLrq).rMrNrOrPrrrcached_propertyrrrwpropertyrsetterrIrLrRrUrXr[rbrPrgrjrmrrrrrrrrrrrrrrrrrrr rQrrs@rHrYrYs)V $=<     '&21('-, O1133..,,((&&11)) ))"&CJ8<! $"%*-1.2=ACG)-3737267;%+%+6:9=59)-.2AM  M  M  M AM 6M M M M M #M  +M ,!M ";#M &A'M (')M *1+M ,1-M .0/M 051M 2#3M 4#5M 647M :7;M <3=M >'?M @,AM ^YY pp ! !))""''J"55 "&$Wr S @9&9-C9 9  ((-(9N( (<+/ ___ ( _  _ _BOO"O O  O O 4:4I"uu PP JPP ! J :D g11rRrYc^^SUU4SjjnU$)zWrap a user message handler so we invalidate `MCPToolset` caches on `list_changed` notifications. The toolset's own cache invalidation runs first, then the user-supplied handler (if any). cr># [USU5n[U[R5(aTR 5 O_[U[R 5(aTR 5 O/[U[R5(aTR5 TbT"U5IShvN ggN7f)Nroot) rr3rzToolListChangedNotificationrgResourceListChangedNotificationrjPromptListChangedNotificationrm)rp notificationr user_handlers rHhandler'_build_message_handler..handlerisw8 lI$I$I J J  + + -  i&O&O P P  / / 1  i&M&M N N  - - /  #w' ' ' $ 'sB+B7.B5/B7)rpr rLrrE)rr r!s`` rHr;r;cs ( ( NrRc USL=(d USL=(d USL=(d USLn[U[5=(d( [U[5=(a URS5nU(aU(d [ S5eU(dU$[U5nUb [ U5OSn [ SU5n [ SU 5n [U5S:Xa[UUU UUbUU S9$SU S9$[UUU UU S9$) afBuild a FastMCP transport from a flexible input. For URL-shaped inputs combined with HTTP-specific kwargs, we construct the transport explicitly so the kwargs take effect (FastMCP's `Client(url, ...)` doesn't forward HTTP kwargs to its auto-inferred transport). For everything else, we pass the input through and let FastMCP's `Client` infer the transport. N)zhttp://zhttps://z`headers`, `http_client`, `auth`, and `verify` only apply to HTTP transports built from a URL string. Pass them on your transport / `fastmcp.Client` directly instead.r sser/)urlr%r#r$sse_read_timeouthttpx_client_factory)r%r%r#r$r') r3rro startswithr8_make_httpx_client_factoryrr1r-r/) rr%r&r#r$r!needs_explicit_httpis_urlr%factorytransport_authtransport_factorys rHr9r9ws "-rD1HrDX\L\r`fnr`r  ' sJvs,C,rHYHYZqHrF6 b    f+C9D9P(5VZG %&NUG,$S)U2-9-E\!2  LR!2   #  .  rRc6^SSU4SjjjnU$)zUReturn an `httpx_client_factory` that always returns the user-supplied `http_client`.c>T$rDrE)r%r1r#follow_redirectsr&s rHr,+_make_httpx_client_factory..factorys rR)NNNT) r%rr1zHTTPTimeout | Noner#zHTTPAuth | Noner1rrLrrE)r&r,s` rHr)r)sR *.&* $"& &#    NrRc(^SU4SjjnU$)zNBuild a FastMCP-shaped sampling handler that delegates to a Pydantic AI model.cN># [R"U5n[[US[5S9nUR =nbXTS'[ US[5nUbXdS'[TX4S9IShvN n[R"S[R"U5TRS9$N87f)N max_tokens)r5 temperaturestop_sequences)model_settingsr)rrr`) r6map_from_mcp_paramsr?r<rqr6r>_STOP_SEQUENCES_ADAPTERr!rzCreateMessageResultmap_from_model_response model_name) sampling_messagesparamsr pai_messagesr8r6r7model_responsers rHr!(_build_sampling_handler..handlers //7 &)FLRU2VW!-- -K :,7= ),V5EG^_  %/=+ ,,^\ii,,00@ ++  jsA'B%*B#+9B%)r>zlist[mcp_types.SamplingMessage]r?z$mcp_types.CreateMessageRequestParamsrr rLzmcp_types.CreateMessageResultrE)rr!s` rHr:r:s3 : 4   '  ( NrRrcUS:Xa[R"US9UeUS:Xa[R"US9UeUS:Xa [U5Ue[ U5 g)Nr)rprr{)r8 ModelRetry ToolFailedr0r)rprrs rHrrsW 7##G4%? X ##G4%? W  e+XrRrcURnUbYU(d![SUR55(a1[U[5(a[ U5S:Xa SU;aUS$U$[ UR5$)zMMap a FastMCP result without discarding structured content on the error path.c3V# UHn[U[R5v M! g7frD)r3rz TextContent)r*rs rHr,,_map_mcp_call_tool_result..s" dUcTD)2G2G!H!HUcs')rrI)rallrr3dictr_map_mcp_tool_results)rIr structureds rHrrsq **JS dU[UcUc ddd j$ ' 'C Oq,@XQ[E[h' '  00rRcnUVs/sHn[U5PM nn[U5S:XaUS$U$s snf)Nrr)_map_mcp_tool_resultr)partsrmappeds rHrLrLs=6; ;UT"4(UF ;F q(6!94f4 $ --..yy ??: & & $..t44 D)00 1 1##!!$)), {C8   D)00 1 1%%!!$)), {C8   D)44 5 5' 66 D)00 1 1488}T)   sF FFc0nUR(a"[RUR5US'UR(aURUS'U=(d S$)Nrmcp_meta)rr^r~r)rrs rH_mcp_part_metadatarb,sN "H &9&F&FtGWGW&X"# yy#yy  trRc*[R"UR5n[U5n[ U[ R 5(a%[R"U[US[5US9$[R"U[US[5US9$)Nr)rtrVvendor_metadata) r\r]rtrbr3rzrZr9r[r<ror_)rrtrds rH_map_mcp_binary_contentre7s   DII &D(.O$ ..//## {C8+   ! ! T;4' rRc[U[R5(a([R"UR[ U5S9$[U[R [R45(a [U5$[U[R5(a)[RU[UR55$[U[R5(a[RU5$[U5 g)N)rr)r3rzrHr9rWrbrZr^rerjr~rrrir)rs rHrrGs$ --..##DII@RSW@XYY D91193I3IJ K K&t,, D)44 5 5,,T3KDMM3Z[[ D)00 1 1((..TrRc ~[U[R5(a UR$[U[R5(ah[ R R[ R "[R"UR5[US[5=(d SS95$[U5 g)Nrzapplication/octet-streamrU)r3rzTextResourceContentsrWBlobResourceContentsr9r_ narrow_typer\r]blobr=ror)rs rHrrTs(I::;;}} Hi<< = =%%11  " "%%hmm4-h SIgMg    XrRch[U[5(aSSjn[RX5nU$[U[5(a/UR 5VVs0sHup#U[ U5_M snn$[U[5(aUVs/sHn[ U5PM sn$U$s snnfs snf)aRecursively expand environment variables in a JSON structure. Environment variables can be referenced using `${VAR_NAME}` syntax, or `${VAR_NAME:-default}` syntax to provide a default value if the variable is not set. Args: value: The value to expand (can be str, dict, list, or other JSON types). Returns: The value with all environment variables expanded. Raises: ValueError: If an environment variable is not defined and no default value is provided. cURS5nURS5SLnU(aURS5OSnU[R;a[RU$U(a U=(d S$[SUS35e)NrrsrzEnvironment variable ${z} is not defined)grouposenvironr8)matchvar_name has_default default_values rH replace_match'_expand_env_vars..replace_matchvsu{{1~H++a.4K.9EKKNtM2::%zz(++$**!#;H:EV!WXXrR)rrz re.Match[str]rLro)r3ro_ENV_VAR_PATTERNsubrKr5_expand_env_varsr)r=rvkvitems rHrzrzds% Y!$$]: E4 38;;=A=41#A&&=AA E4 38954 &599 B9s B)B/cV\rSrSr%SrS\S'S\S'S\S'S \S 'S\S 'S\S 'S rg)_MCPServerConfigiuThe keys `load_mcp_toolsets` reads from an `mcpServers` entry. Unknown keys are ignored rather than rejected, so a configuration file shared with another MCP client still loads. They are only ignored, never honoured: `disabled` does not skip a server, and `type` does not select the transport — that is inferred from the URL. Optional transport values accept explicit JSON `null` for compatibility with existing shared MCP configuration files; loading treats those values the same as omission. rocommandrrrenvrcwdr%r%rEN)rMrNrOrPrrrQrErRrHrrs*L   O H ""rRr)totalc \rSrSr%S\S'Srg) _MCPConfigizdict[str, _MCPServerConfig] mcpServersrEN)rMrNrOrPrrQrErRrHrrs++rRrc [U5nUR5(d[SUS35e[R"UR 55n[ R[U55n/nUSR5HupESU;aX[US[URS5=(d /5URS5URS5S9n[XdS 9nO3S U;a[US XERS 5S 9nO[S U<S35eURUR!U55 M U$)uELoad `MCPToolset`s from a configuration file. The configuration file uses the same `mcpServers` JSON shape as Claude Desktop, Claude Code, and Cursor. Each server entry produces one [`MCPToolset`][pydantic_ai.mcp.MCPToolset], wrapped in a [`PrefixedToolset`][pydantic_ai.toolsets.PrefixedToolset] using the server's name as prefix to disambiguate tools across multiple servers. Environment variables can be referenced in the configuration file using: - `${VAR_NAME}` syntax — expands to the value of `VAR_NAME`, raises if not defined - `${VAR_NAME:-default}` syntax — expands to `VAR_NAME` if set, otherwise the default Args: config_path: Path to the JSON configuration file. Returns: A list of toolsets, one per server in the config file, each prefixed with the server name. Raises: OSError: If the configuration file does not exist (`FileNotFoundError`), or exists but cannot be read — a directory, or a file without read permission. ValidationError: If the configuration does not match the `mcpServers` shape above. This is a `ValueError` subclass, so catching `ValueError` covers it too. ValueError: If the file is not valid JSON, a server entry has neither `command` nor `url`, or an environment variable referenced in the configuration is not defined and no default is provided. z Config file z not foundrrrrr)rrrr)rr%r%)rr%zMCP server config z$ must have either `command` or `url`)r existsFileNotFoundErrorrXrY read_bytes_MCP_CONFIG_ADAPTERvalidate_pythonrzr5r.rrrYr8r6prefixed) config_path config_dataconfigtoolsetsrserverr0rs rHr[r[s'8{#K     ,{m: FGG))+*@*@*BCK 0 01A+1N OF+-H|,224   &y)&**V,23JJu%JJu% I !4G f_ 4IAVWG1$9]^_ _((./5 OrR)rLr)rzMCPToolset[Any]r rrLr')rrZr%rr&rr#r r$rr!r rLrZ)r&rrLzCallable[..., AsyncHTTPClient])rrrLzSamplingHandler[Any, Any])rprorrrzBaseException | NonerLr)rIr4rrrLr )rPz Sequence[mcp_types.ContentBlock]rLz{str | messages.BinaryContent | dict[str, Any] | list[Any] | list[str | messages.BinaryContent | dict[str, Any] | list[Any]])rmcp_types.ContentBlockrLz9str | messages.BinaryContent | dict[str, Any] | list[Any])rzGmcp_types.TextContent | mcp_types.ImageContent | mcp_types.AudioContentrLrs)rz/mcp_types.ImageContent | mcp_types.AudioContentrLzmessages.BinaryContent)rrrLrk)rz?mcp_types.TextResourceContents | mcp_types.BlobResourceContentsrLr)r=r rLr )rz str | PathrLzlist[AbstractToolset[Any]]) __future__rr\rrpresslr|abcrcollections.abcrrr contextlibr dataclassesr pathlibr typingr r r rrrrrrrrXpydanticrrrtyping_extensionsrrrpydantic_ai.toolsrrr_httprrr directr!toolsets.abstractr"r#fastmcp.clientr$r4fastmcp.client.elicitationr%fastmcp.client.loggingr&fastmcp.client.messagesr'fastmcp.client.progressr(fastmcp.client.rootsr)r*fastmcp.client.samplingr+fastmcp.client.transportsr,r-r.r/fastmcp.exceptionsr0fastmcp.mcp_configr1rU _import_errorr2mcpr3rzfastmcp.client.clientr4fastmcp.serverr5mcp.server.fastmcpFastMCP1Serverrnr6r7r8r9r: _mcp_compatr;r<r=r>settingsr?r2rKrorrr:rArVrX__all__ RuntimeErrorr\r^rhrr]r_rirerdrlrjrHr_rkrfrgr`SchemaValidator core_schema dict_schema str_schema any_schemarcompilerx_SHUTDOWN_GRACE_SECONDSrcrbrarZrrrrYr;r9r)r:rrrLrOrbrerrrzrrrr[rErRrHrs"  99%!hhh //;;DD :9!;6=177<7 -@(" 4&<*@ 98ZZ#o "4S>2%d3i022i 223 = 0$5|$5N t$  % B t$ 3 3% 3 t$333%36 t$( |( %( V t$$ |$ %$ N t$E E %E P t$33%3$ t$= = %= @( )  t$- - %- `##h&<&<<|KN^^ C t$ 3 3% 3 t$33%3$ t$6 6 %6 r&55  $ $ 0 0!!,,. 0I0I0T0T0V ::;< 38n 3isX+++d38n QQ QQQ*)Q*