iG UdZddlmZddlZddlZddlZddlZddlmZm Z m Z m Z ddl m Z mZddlmZddlmZddlmZdd lmZmZmZmZmZmZmZddlZddlZdd l m!Z!dd l"m#Z#dd l$m%Z%dd l&m'Z'ddl(m)Z)ddlm*Z*m+Z+m,Z,m-Z-ddl.m/Z/ddl.m0Z1ddl2m3Z3ddl4m5Z5ddl6Z6ddl7Z6ddl8m9Z9m:Z:m;Z;mZ>m0Z0ddl?m@Z@ddlAmBZBddlCmDZDddlEmFZFddlGmHZHmIZIddlJmKZKddlLmMZMmNZNmOZOddlPmQZQmRZRmSZSmTZTddlUmVZVddlWmXZXddlYmZZZm[Z[dd l\m]Z]m^Z^m_Z_dd!l`maZambZbdd"lcmdZddd#lemfZfmgZgdd$lhmiZidd%ljmkZkmlZldd&lmmnZnmoZodd'lpmqZrdd(lsmtZtdd)lumvZvmwZwdd*lxmyZydd+lzm{Z{dd,l|m}Z}dd-l~mZmZmZdd.lmZer2dd/lmZdd0lmZdd1lmZdd2lmZmZdd3lmZdd4lmZdd5lmZdd6lmZe}eZed7e d8ef9Zed:Zqid;d<d=d>d?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdNdPdNdQdRdSdTdUdVdWdXZdYedZ<dgd[Zed\Zej8d]Ze d^ge e'fZdhd_Zedid`Z djdaZGdbdceZGdddeede]e^e_ee'Z dkdfZy)lz5FastMCP - A more ergonomic interface for MCP servers.) annotationsN) AsyncIterator AwaitableCallableSequence)AbstractAsyncContextManagerasynccontextmanager)replace)partial)Path) TYPE_CHECKINGAnyGenericLiteralTypeVarcastoverload)PydanticAdapter) AsyncKeyValue) MemoryStore)LifespanResultT)McpError) Annotations AnyFunctionCallToolRequestParamsToolAnnotations)AnyUrl)ValidationError) BaseRoute)Self)AuthorizationError FastMCPError NotFoundError PromptError ResourceError ToolErrorr) MCPConfig)Prompt)FunctionPrompt) PromptResult)ResourceResourceResult)ResourceTemplate) AppConfigapp_config_to_meta_dictresolve_ui_mime_type) AuthCheck AuthContext AuthProviderrun_auth_checks)Lifespan)LowLevelServer) MiddlewareMiddlewareContext) LifespanMixinMCPOperationsMixinTransportMixin) LocalProviderProvider)AggregateProvider) TaskConfigTaskMeta) server_span) ToolTransform Transform)apply_session_transforms is_enabled)DuplicateBehavior) FunctionTool)Tool ToolResult)ToolTransformConfig)FastMCPComponent) get_logger)FastMCPBaseModelNotSetNotSetT) VersionSpec)Client)FastMCP1Server)SamplingHandler)ClientTransportClientTransportT) ComponentFn)RouteMap) RouteMapFn FastMCPProxyF.)bound)warnerrorr ignorehostz7Pass `host` to `run_http_async()`, or set FASTMCP_HOST.portz7Pass `port` to `run_http_async()`, or set FASTMCP_PORT.sse_pathzKPass `path` to `run_http_async()` or `http_app()`, or set FASTMCP_SSE_PATH. message_pathzSet FASTMCP_MESSAGE_PATH.streamable_http_pathzWPass `path` to `run_http_async()` or `http_app()`, or set FASTMCP_STREAMABLE_HTTP_PATH. json_responsezYPass `json_response` to `run_http_async()` or `http_app()`, or set FASTMCP_JSON_RESPONSE.stateless_httpz[Pass `stateless_http` to `run_http_async()` or `http_app()`, or set FASTMCP_STATELESS_HTTP.debugzSet FASTMCP_DEBUG. log_levelzAPass `log_level` to `run_http_async()`, or set FASTMCP_LOG_LEVEL.on_duplicate_toolszUse `on_duplicate=` instead.on_duplicate_resourceson_duplicate_promptstool_serializerzgReturn ToolResult from your tools instead. See https://gofastmcp.com/servers/tools#custom-serialization include_tagszCUse `server.enable(tags=..., only=True)` after creating the server. exclude_tagsz9Use `server.disable(tags=...)` after creating the server.tool_transformationszIUse `server.add_transform(ToolTransform(...))` after creating the server.zdict[str, str]_REMOVED_KWARGSc|D]"}|tvs td|dt||r$tddjd|Dy)z2Raise helpful TypeErrors for kwargs removed in v3.zFastMCP() no longer accepts `z`. z.FastMCP() got unexpected keyword argument(s): z, c32K|]}t|ywN)repr).0ks e/Users/bowang/.openclaw/workspace/ChatDev/.venv/lib/python3.12/site-packages/fastmcp/server/server.py z(_check_removed_kwargs..sF_X^STtAwX^sN)rp TypeErrorjoin)kwargskeys rw_check_removed_kwargsr}~si / !/uC8L7MN  .wrapsJ  # #'7 7H 22^  ---sAA)rzLowLevelServer[LifespanResultT]returnzAsyncIterator[LifespanResultT])r )rrs` rw_lifespan_proxyrs.  .9 . ' . . Kr~ceZdZUdZded<y) StateValuez(Wrapper for stored context state values.rvalueN)__name__ __module__ __qualname____doc____annotations__rr~rwrrs 2 Jr~rc:eZdZ dCddddddddddddddddddd dDfdZdEdZedEdZedFdZejdGdZedFd Z edFd Z edHd Z edId Z dJd Z dKdZdddLfdZdMfd ZdNdZ dOdZdPdZdddQfdZ dR dSfd Z dR dSfd Zdd dTfdZ dR dUfd Z dR dUfd Zdd dVfdZ dR dWfd Z dR dWfd ZdddXfd Z dR dYfd! Z dR dYfd" Ze dRdddd# dZd$Z!e dRddd% d[d&Z! dRdddd# d\d'Z!e dddd# d]d(Z"e ddd% d^d)Z"dddd# d_d*Z"e dRdddd# d`d+Z#e dRddd% d[d,Z# dRdddd# dad-Z#dbd.Z$dRdcd/Z%e dddddde&dddddddd0 ddd1Z'e dRdddddde&dddddddd0 ded2Z' dRdddddde&dddddddd0 dfd3Z' dgd4Z(dhd5Z)ddddddddddddd6 did7Z*djd8Z+e dddddddddd9 dkd:Z,e dRdddddddddd9 dld;Z, dRdddddddddd9 dmd<Z, dn dod=Z- dR dpd>Z.e/ dq drd?Z0e/ ds dtd@Z1e/ dudAZ2e/dRdvdBZ3xZ4S)wFastMCPNT)version website_urliconsauth middleware providers transformslifespantools on_duplicatemask_error_detailsdereference_schemasstrict_input_validationlist_page_sizetaskssession_state_storesampling_handlersampling_handler_behaviorc Jt|t| | xsd|_||nd|_d|_d|_g|_|xs t|_ tt|jtd|_ t|j|_|j|j|xsgD]}|j|| xsgD]}|j!|| | nt"j$j&|_||dkr t+d||_| t/t0t2| |_n t/t0t2t6|_d|_d|_t=j>|_ tCt2||xs|jE|xst"jF|||tI| |_%||_&| r=| D]8}tO|tPstQjR|}|jU|:||nt"j$jV|_+tY|xsg|_-|r&dd l.m/}|jZja||jc||_2|xsd |_3y) Nr]F fastmcp_state) key_valuepydantic_modeldefault_collection)rrz)list_page_size must be a positive integer)r)fastmcpnamer instructionsrrr)DereferenceRefsMiddlewarefallback)4r}super__init__ _on_duplicate_support_tasks_by_default_docket_worker_additional_http_routesr_state_storagerr _state_storer<_local_provider add_provider add_transformrsettingsr_mask_error_details ValueError_list_page_sizerLifespanCallablerrrrrasyncioEvent_startedr6 generate_name __version__r _mcp_serverr isinstancerH from_functionadd_toolrlistr%fastmcp.server.middleware.dereferencerappend_setup_handlersrr)selfrrrrrrrrrrrrrrrrrrrrr{pttoolr __class__s rwrzFastMCP.__init__s2 f% 7C7Mv9>8Iuu&  8:$.A-QKM9H9T))%.: /<++/  $../bA   a !!r!A   q !" "- !!44    %.A*=HI I+9  @D 18ADN""2?"CEUVDN8<*/!'.}} BP B -++-2w22%#$D9 B *. !$---d3D d#'2 $!!99 $ -11Ar,B   OO " "#<#> ? 8H % 3 &r~cLt|jd|jdS)N())typerrrs rw__repr__zFastMCP.__repr__]s$t*%%&a }A66r~c.|jjSrs)rrrs rwrz FastMCP.name`s$$$r~c.|jjSrsrrrs rwrzFastMCP.instructionsds,,,r~c&||j_yrsr)rrs rwrzFastMCP.instructionshs(-%r~c.|jjSrs)rrrs rwrzFastMCP.versionls'''r~c.|jjSrs)rrrs rwrzFastMCP.website_urlps+++r~cp|jjgSt|jjSrs)rrrrs rwrz FastMCP.iconsts0    ! ! )I((../ /r~c|jS)a)The server's local provider, which stores directly-registered components. Use this to remove components: mcp.local_provider.remove_tool("my_tool") mcp.local_provider.remove_resource("data://info") mcp.local_provider.remove_prompt("my_prompt") )rrs rwlocal_providerzFastMCP.local_provider{s###r~cK|}t|jD]}t||}||d{S7w)z)Builds and executes the middleware chain.) call_nextN)reversedrr )rcontextrchainmws rw_run_middlewarezFastMCP._run_middlewares< 4??+BB%0E,7^###s 5><>c:|jj|yrs)rr)rrs rwadd_middlewarezFastMCP.add_middlewares z*r~ namespacec(t|||y)a\Add a provider for dynamic tools, resources, and prompts. Providers are queried in registration order. The first provider to return a non-None result wins. Static components (registered via decorators) always take precedence over providers. Args: provider: A Provider instance that will provide components dynamically. namespace: Optional namespace prefix. When set: - Tools become "namespace_toolname" - Resources become "protocol://namespace/path" - Prompts become "namespace_promptname" rN)rr)rproviderrrs rwrzFastMCP.add_providers X;r~cKtt| d{}|Dcgc]}t|ts|}}|Dcgc]}t|t s|}}|Dcgc]}t|t s|}}|Dcgc]}t|ts|}}|jD]f}|j|d{}|j|d{}|j|d{}|j|d{}hg||||S7cc}wcc}wcc}wcc}w7r7[7D7-w)zGet task-eligible components with all transforms applied. Overrides AggregateProvider.get_tasks() to apply server-level transforms after aggregation. AggregateProvider handles provider-level namespacing. N) rr get_tasksrrHr+r-r(r list_toolslist_resourceslist_resource_templates list_prompts) r componentscr resources templatesprompts transformrs rwrzFastMCP.get_taskssC 1 334 '>Jq*Q*=J> *F 1jH.EQ F *N 1j |j'| Q|cdddd{S7'7777cc}w7<#t$$rYwxYw7&#1d{7swYyxYww) a List all enabled tools from providers. Overrides Provider.list_tools() to add visibility filtering, auth filtering, and middleware execution. Returns all versions (no deduplication). Protocol handlers deduplicate for MCP wire format. rNz tools/list)methodclientrequestmessagesourcerrfastmcp_contextc(jdSNFr)rrrs rwz$FastMCP.list_tools..sdooUo.Sr~rrtoken component)rrrContextr8mcptypesListToolsRequestrrrrrDrErrr2r4r!r) rrctx mw_contextrr skip_authr, authorizedrrs ` rwrzFastMCP.list_toolssz>>))11$1??3.II66l6K#"'$'  "11&S2@??uw1334E2599E %71AQE702 Iu%'J TYY%:%ETBC!%4TYY%DDD$ E!!$'=@??@497 E-! !7@???s/FEFA E=EE= FEFE=-E! .E=E#E= E%E%"1E=E,-E*.E,2E= FE;FE=F!E=#E=%E=*E,, E85E=7E88E=;F=FF F FcKt|||d{}|yt\}}|s<|j0t ||} t |j|d{sy |S|S7T7 #t $rYywxYww)acGet a tool by name via aggregation from providers. Extends AggregateProvider._get_tool() with component-level auth checks. Args: name: The tool name. version: Version filter (None returns highest version). Returns: The tool if found and authorized, None if not found or unauthorized. Nr+)r _get_toolrrr2r4r!)rrrrr4r,r2rs rwr7zFastMCP._get_tool#sW&tW55 <-. 5TYY2ET:C ,TYY<<<=  t 6=%  KA?A,/A?A0!A."A0&A?(A?.A00 A<9A?;A<<A?cKt|||d{}|yt|gd{}|rt|dsy|dS717w)aGet a tool by name, filtering disabled tools. Overrides Provider.get_tool() to add visibility filtering after all transforms (including session-level) have been applied. This ensures session transforms can override provider-level disables. Args: name: The tool name. version: Version filter (None returns highest version). Returns: The tool if found and enabled, None otherwise. Nr)rget_toolrDrE)rrrrrrs rwr:zFastMCP.get_toolBs[ W%dG44 </v66JuQx0Qx5 7A A A A A  A cKtjjj4d{}|r?t iddd|}j |fdd{cdddd{St t !d{}t|d{}|Dcgc]}t|s|}}t\}}g}|D]O} |s:| j.t|| } t| j|d{s> |j!| Q|cdddd{S7 7777cc}w7<#t$rYwxYw7&#1d{7swYyxYww) aList all enabled resources from providers. Overrides Provider.list_resources() to add visibility filtering, auth filtering, and middleware execution. Returns all versions (no deduplication). Protocol handlers deduplicate for MCP wire format. rNr r!zresources/listr"c(jdSr')rr(s rwr)z(FastMCP.list_resources..psd.A.AQV.A.Wr~r*r+)rrrr.r8rrrrrDrErrr2r4r!r) rrr2r3rrr4r,r5resourcers ` rwrzFastMCP.list_resources\sh>>))11$1??3.#"+$'  "11&W2@??57#9#;;%EXFC!%4X]]C%HHH$ I!!(+&=@??@<A? I-! !7@???/E4D<E4,E#D?$E' E43E4E49EE E&E'E/EE1E6EE EE* E46E7E4?EE4EEE E EEEEE4E1%E( &E1-E4cKt|||d{}|yt\}}|s<|j0t ||} t |j|d{sy |S|S7T7 #t $rYywxYww)apGet a resource by URI via aggregation from providers. Extends AggregateProvider._get_resource() with component-level auth checks. Args: uri: The resource URI. version: Version filter (None returns highest version). Returns: The resource if found and authorized, None if not found or unauthorized. Nr+)r _get_resourcerrr2r4r!)rurirr?r4r,r2rs rwrBzFastMCP._get_resources.sG<<  -. 5X]]6EX>C ,X]]C@@@A x=A%  r8cKt|||d{}|yt|gd{}|rt|dsy|dS717w)aGet a resource by URI, filtering disabled resources. Overrides Provider.get_resource() to add visibility filtering after all transforms (including session-level) have been applied. Args: uri: The resource URI. version: Version filter (None returns highest version). Returns: The resource if found and enabled, None otherwise. Nr)r get_resourcerDrE)rrCrr?rrs rwrEzFastMCP.get_resources]-c7;;  3H:>>  9Q< 8|< ?r;cKtjjj4d{}|r?t iddd|}j |fdd{cdddd{St t !d{}t|d{}|Dcgc]}t|s|}}t\}}g}|D]O} |s:| j.t|| } t| j|d{s> |j!| Q|cdddd{S7 7777cc}w7<#t$rYwxYw7&#1d{7swYyxYww) a%List all enabled resource templates from providers. Overrides Provider.list_resource_templates() to add visibility filtering, auth filtering, and middleware execution. Returns all versions (no deduplication). Protocol handlers deduplicate for MCP wire format. rNr r!zresources/templates/listr"c(jdSr')rr(s rwr)z1FastMCP.list_resource_templates..sd.J.J',/K/r~r*r+)rrrr.r8rrrrrDrErrr2r4r!r) rrr2r3r rr4r,r5templaters ` rwrzFastMCP.list_resource_templatessl>>))11$1??3.#"5$'  "11&2@??"57#B#DDEI6yAAI$-?IqAII?02 Iu13J% X]]%>%EXFC!%4X]]C%HHH$ I!!(+&A@??@"EA? I-! !;@???r@cKt|||d{}|yt\}}|s<|j0t ||} t |j|d{sy |S|S7T7 #t $rYywxYww)aGet a resource template by URI via aggregation from providers. Extends AggregateProvider._get_resource_template() with component-level auth checks. Args: uri: The template URI to match. version: Version filter (None returns highest version). Returns: The template if found and authorized, None if not found or unauthorized. Nr+)r_get_resource_templaterrr2r4r!)rrCrrHr4r,r2rs rwrJzFastMCP._get_resource_templates7WEE  -. 5X]]6EX>C ,X]]C@@@A xFA%  r8cKt|||d{}|yt|gd{}|rt|dsy|dS717w)aGet a resource template by URI, filtering disabled templates. Overrides Provider.get_resource_template() to add visibility filtering after all transforms (including session-level) have been applied. Args: uri: The template URI. version: Version filter (None returns highest version). Returns: The template if found and enabled, None otherwise. Nr)rget_resource_templaterDrE)rrCrrHr rs rwrLzFastMCP.get_resource_templates^6sGDD  3H:>>  9Q< 8|E ?r;cKtjjj4d{}|r?t iddd|}j |fdd{cdddd{St t !d{}t|d{}|Dcgc]}t|s|}}t\}}g}|D]O} |s:| j.t|| } t| j|d{s> |j!| Q|cdddd{S7 7777cc}w7<#t$rYwxYw7&#1d{7swYyxYww) aList all enabled prompts from providers. Overrides Provider.list_prompts() to add visibility filtering, auth filtering, and middleware execution. Returns all versions (no deduplication). Protocol handlers deduplicate for MCP wire format. rNr r!z prompts/listr"c(jdSr')rr(s rwr)z&FastMCP.list_prompts..2sd.?.?u.?.Ur~r*r+)rrrr.r8rrrrrDrErrr2r4r!r) rrr2r3r rr4r,r5promptrs ` rwrzFastMCP.list_prompts sh>>))11$1??3.#")$'  "11&U2@??!5!778G4W==G");'QZ]q'G;02 Iu')J! V[[%<%EVDC!%4V[[#%FFF$ G!!&)"=@??@8=; G-! !7@???r@cKt|||d{}|yt\}}|s<|j0t ||} t |j|d{sy |S|S7T7 #t $rYywxYww)akGet a prompt by name via aggregation from providers. Extends AggregateProvider._get_prompt() with component-level auth checks. Args: name: The prompt name. version: Version filter (None returns highest version). Returns: The prompt if found and authorized, None if not found or unauthorized. Nr+)r _get_promptrrr2r4r!)rrrrOr4r,r2rs rwrQzFastMCP._get_promptGsw*499 >-. 5V[[4EV>>?  v :?%  r8cKt|||d{}|yt|gd{}|rt|dsy|dS717w)aGet a prompt by name, filtering disabled prompts. Overrides Provider.get_prompt() to add visibility filtering after all transforms (including session-level) have been applied. Args: name: The prompt name. version: Version filter (None returns highest version). Returns: The prompt if found and enabled, None otherwise. Nr)r get_promptrDrE)rrrrOr rs rwrSzFastMCP.get_promptfs\w)$88 >1&::j4qz9 ;r;rr task_metac Kywrsrrr argumentsrrrUs rw call_toolzFastMCP.call_tools )rrc KywrsrrWs rwrYzFastMCP.call_tool &)rZc bKtjjj4d{}|rkt t t jj ||xsiddd|}j|fd d{cdddd{Std |djd |5}j| d{} | td ||j| j#jt!| j" | j%|xsid{cdddcdddd{S787777'7#t&$rt(j+d|t,t.f$rt(j+d|t0$r} t(j+d|t3| t4j6r%| j8j:dk(r t=d| t3| t4j>r t=d| j@rt=d|| t=d|d| | d} ~ wwxYw#1swYnxYwdddd{7y#1d{7swYyxYww)aCall a tool by name. This is the public API for executing tools. By default, middleware is applied. Args: name: The tool name arguments: Tool arguments (optional) version: Specific version to call. If None, calls highest version. run_middleware: If True (default), apply the middleware chain. Set to False when called from middleware to avoid re-applying. task_meta: If provided, execute as a background task and return CreateTaskResult. If None (default), execute synchronously and return ToolResult. Returns: ToolResult when task_meta is None. CreateTaskResult when task_meta is provided. Raises: NotFoundError: If tool not found or disabled ToolError: If tool execution fails ValidationError: If arguments fail validation rNrrXr r!z tools/callr"cj|jj|jjxsidSNFrT)rYr#rrXrrrUrs rwr)z#FastMCP.call_tool..s;dnn,,117R '',"+ /=/r~r*z tools/call rrzUnknown tool: fn_keyrUzError calling tool zError validating tool 0Rate limited by upstream API, please retry later(Upstream request timed out, please retry: )!rrrr.r8rr/r0rrArr:r#set_attributesget_span_attributesrdr r|_runr"logger exceptionrPydanticValidationError ExceptionrhttpxHTTPStatusErrorresponse status_coder&TimeoutExceptionr) rrrXrrrUr2r3spanres ` ` ` rwrYzFastMCP.call_toolsH>>))11$1??3./DEII;;!Y_"<$"'$' "11&2  @??0dV$lDIIvt!]]4]AA<'.(ABB##D$<$<$>?(Y-=-=-E ' $(( CIP!%9?i!PP1@?? @6BQE@F$$$':4(%CD')@A$$'=dX%FG P$$':4(%CD"!U%:%:;::11S8"+ R##$%"!U%;%;<'F !//'*=dX(FGQN#&9$A3$GHaO!P#1@????s/J/E,J/AJE/J J/ E1!J/&JI<E3AI<3E9 E5E9 J J/&E7'J//J1J/3I<5E97J/9AI9 B*I44I99I<<J J J/JJ/J, J# !J,(J/c KywrsrrrCrrrUs rw read_resourcezFastMCP.read_resources rZc Kywrsrrys rwrzzFastMCP.read_resources &)rZc rKtjjj4d{}|rjt |}t t jj|ddd|}j|fd d{cdddd{Std |djd || 5}j| d{} | y|j| j#jt!| j" | j%d{cdddcdddd{SjA| d{} | !tCd|tCd|d|j| j| jE|} | J#jt!| j" | j%|| d{cdddcdddd{S7777W77#t&t(f$rt*j-d|t.$r} t*j-d|t1| t2j4r%| j6j8dk(r t;d| t1| t2j<r t;d| j>rt;d|| t;d|d| | d} ~ wwxYw777#t&t(f$rt*j-d|t.$r} t*j-d|t1| t2j4r%| j6j8dk(r t;d| t1| t2j<r t;d| j>rt;d|| t;d|d| | d} ~ wwxYw#1swYnxYwdddd{7y#1d{7swYyxYww)aRead a resource by URI. This is the public API for reading resources. By default, middleware is applied. Checks concrete resources first, then templates. Args: uri: The resource URI version: Specific version to read. If None, reads highest version. run_middleware: If True (default), apply the middleware chain. Set to False when called from middleware to avoid re-applying. task_meta: If provided, execute as a background task and return CreateTaskResult. If None (default), execute synchronously and return ResourceResult. Returns: ResourceResult when task_meta is None. CreateTaskResult when task_meta is provided. Raises: NotFoundError: If resource not found or disabled ResourceError: If resource read fails rN)rCr r!zresources/readr"chjt|jjdSr`)rzstrr#rCras rwr)z'FastMCP.read_resource..9s1d.@.@GOO//0 '',"+ /A/r~r*zresources/read r?) resource_urirbrcrezError reading resource rfrgrhrizUnknown resource: version )#rrrr.rr8r/r0ReadResourceRequestParamsrrArrErjrkrdr r|_readr"rrmrnrprrqrrrsrtr%rurrLr#matches) rrCrrrUr2 uri_paramr3rvr?rwrHparamss ` ` ` rwrzzFastMCP.read_resourcesIJ>>))11$1??3"3K .II??I?N#"+$'  "11&2@??*!#'   !%!2!23!2!HH'''(D(D(FG ,1A1A1I$+Ihll$K !%-^^i^%HH+@??|"&!;!;C!;!QQ#+.@,HII',SG9WKH##H$@$@$BC!))#.)))(Y-=-=-E ' (,, GIW!)Vy!QQm+@??@<I II@J)(3((+B3')JK$!((+B3')JK%a)>)>? zz55<&3$V'"'(!)&a)?)?@"/ J##$% 33"/"9# A##$%,5cWBqcB !#!,RRW@X%h/$$'>sg%FG W$$'>sg%FG!!U%:%:;::11S8"/ R##$%"!U%;%;<+F !//+.EcW,MNTUU'*A#1#(NOUVVWu+@????sE/P7H(P7AP"H+P" P7H. P7%P"PH1A P&H8;H4<H8? P" P7H6P7P0L1BP2L" L L" P" P7"L #P7+P".P71P4H86P780L(B*LLPL" P7"0PB*O<<PPP P" P7PP7"P4(P+ )P40P7c KywrsrrWs rw render_promptzFastMCP.render_prompts rZc KywrsrrWs rwrzFastMCP.render_promptr\rZc 8Ktjjj4d{}|r`t t j j||ddd|}j|fd d{cdddd{Std |djd |5}j| d{} | td ||j| j#jt!| j" | j%|d{cdddcdddd{S7)7777'7#t&t(f$rt*j-d|t.$rJ} t*j-d|j0rt3d|| t3d|d| | d} ~ wwxYw#1swYnxYwdddd{7y#1d{7swYyxYww)aRender a prompt by name. This is the public API for rendering prompts. By default, middleware is applied. Use get_prompt() to retrieve the prompt definition without rendering. Args: name: The prompt name arguments: Prompt arguments (optional) version: Specific version to render. If None, renders highest version. run_middleware: If True (default), apply the middleware chain. Set to False when called from middleware to avoid re-applying. task_meta: If provided, execute as a background task and return CreateTaskResult. If None (default), execute synchronously and return PromptResult. Returns: PromptResult when task_meta is None. CreateTaskResult when task_meta is provided. Raises: NotFoundError: If prompt not found or disabled PromptError: If prompt rendering fails rNr^r r!z prompts/getr"cj|jj|jjdSr`)rr#rrXras rwr)z'FastMCP.render_prompt..s9d.@.@,,11 '',"+ /A/r~r*z prompts/get rOrbzUnknown prompt: rcrezError rendering prompt ri)rrrr.r8r/r0GetPromptRequestParamsrrArrSr#rjrkrdr r|_renderr"rrmrnrprr$) rrrXrrrUr2r3rvrOrws ` ` ` rwrzFastMCP.render_prompts@>>))11$1??3.II<<!Y=$"($' "11&2  @??0tf%}dii4#tWEE>'*:4((CDD##F$>$>$@A(Y-=-=-E ' &** EI V!' Y!OO1@?? @6FPE@F%h/$$'>th%GH V$$'>th%GH//),CD8*LMSTT%(?xr!&MNTUU V1@????s/HEHA HE H HE"HH7G'E$AG'(E*>E&?E* H HE(H H"H$G'&E*(H*0G$AGG$$G''G0 ,H3 H>H?HH H HHc8|jj|S)atAdd a tool to the server. The tool function can optionally request a Context object by adding a parameter with the Context type annotation. See the @tool decorator for examples. Args: tool: The Tool instance or @tool-decorated function to register Returns: The tool instance that was added to the server. )rr)rrs rwrzFastMCP.add_tools##,,T22r~ctjjrtjdt d |j j||y#t$r&|td|ddtd|d|ddwxYw)akRemove tool(s) from the server. .. deprecated:: Use ``mcp.local_provider.remove_tool(name)`` instead. Args: name: The name of the tool to remove. version: If None, removes ALL versions. If specified, removes only that version. Raises: NotFoundError: If no matching tool is found. zNremove_tool() is deprecated. Use mcp.local_provider.remove_tool(name) instead.rrNzTool z not foundr) rrrrr]rr remove_toolKeyErrorr#)rrrs rwrzFastMCP.remove_tools    0 0 MM@"      , ,T7 ; #eD8:$>?TIxy :>  s A/B)rrtitle descriptionrtags output_schemar exclude_argsmetaapptasktimeoutrcyrsrr name_or_fnrrrrrrrrrrrrrrs rwrz FastMCP.tools& r~cyrsrrs rwrz FastMCP.tool/s&r~c| +| dur'| r t| ni} | durd| d<nt| | d<|jj||||||||| | | | | n |j||}|S)aDecorator to register a tool. Tools can optionally request a Context object by adding a parameter with the Context type annotation. The context provides access to MCP capabilities like logging, progress reporting, and resource access. This decorator supports multiple calling patterns: - @server.tool (without parentheses) - @server.tool (with empty parentheses) - @server.tool("custom_name") (with name as first argument) - @server.tool(name="custom_name") (with name as keyword argument) - server.tool(function, name="custom_name") (direct function call) Args: name_or_fn: Either a function (when used as @tool), a string name, or None name: Optional name for the tool (keyword-only, alternative to name_or_fn) description: Optional description of what the tool does tags: Optional set of tags for categorizing the tool output_schema: Optional JSON schema for the tool's output annotations: Optional annotations about the tool's behavior exclude_args: Optional list of argument names to exclude from the tool schema. Deprecated: Use `Depends()` for dependency injection instead. meta: Optional meta information about the tool Examples: Register a tool with a custom name: ```python @server.tool def my_tool(x: int) -> str: return str(x) # Register a tool with a custom name @server.tool def my_tool(x: int) -> str: return str(x) @server.tool("custom_name") def my_tool(x: int) -> str: return str(x) @server.tool(name="custom_name") def my_tool(x: int) -> str: return str(x) # Direct function call server.tool(my_function, name="custom_name") ``` FTui) rrrrrrrrrrrrr)dictr/rrr)rrrrrrrrrrrrrrrrresults rwrz FastMCP.toolDsP ?s%/!%4:2Dd{!T 4S9T %%** #'#%)t/M/M+ " r~c8|jj|S)zAdd a resource to the server. Args: resource: A Resource instance or @resource-decorated function to add Returns: The resource instance that was added to the server. )r add_resource)rr?s rwrzFastMCP.add_resources##00::r~c8|jj|S)zAdd a resource template to the server. Args: template: A ResourceTemplate instance to add Returns: The template instance that was added to the server. )r add_template)rrHs rwrzFastMCP.add_templates##00::r~) rrrrr mime_typerrrrrrc t|ts tdt||}t| tr.| j t d| j t d| +| dur'| r t| ni} | durd| d<nt| | d<|jj||||||||| | | | n |j|  }|S)aDecorator to register a function as a resource. The function will be called when the resource is read to generate its content. The function can return: - str for text content - bytes for binary content - other types will be converted to JSON Resources can optionally request a Context object by adding a parameter with the Context type annotation. The context provides access to MCP capabilities like logging, progress reporting, and session information. If the URI contains parameters (e.g. "resource://{param}") or the function has parameters, it will be registered as a template resource. Args: uri: URI for the resource (e.g. "resource://my-resource" or "resource://{param}") name: Optional name for the resource description: Optional description of the resource mime_type: Optional MIME type for the resource tags: Optional set of tags for categorizing the resource annotations: Optional annotations about the resource's behavior meta: Optional meta information about the resource Examples: Register a resource with a custom name: ```python @server.resource("resource://my-resource") def get_data() -> str: return "Hello, world!" @server.resource("resource://my-resource") async get_data() -> str: data = await fetch_data() return f"Hello, world! {data}" @server.resource("resource://{city}/weather") def get_weather(city: str) -> str: return f"Weather for {city}" @server.resource("resource://{city}/weather") async def get_weather_with_context(city: str, ctx: Context) -> str: await ctx.info(f"Fetching weather for {city}") return f"Weather for {city}" @server.resource("resource://{city}/weather") async def get_weather(city: str) -> str: data = await fetch_weather(city) return f"Weather for {city}: {data}" ``` zThe @resource decorator was used incorrectly. It requires a URI as the first argument. Use @resource('uri') instead of @resourceuresource_uri cannot be set on resources — the resource itself is the UI. Use resource_uri on tools to point to a UI resource.uCvisibility cannot be set on resources — it only applies to tools.FTr) rrrrrrrrrrr) rr~ryr0r.rr visibilityrr/rr?r)rrCrrrrrrrrrrrrinner_decorators rwr?zFastMCP.resourcesJ#s#< )i8  c9 %+ K ~~) Y ?s%/!%4:2Dd{!T 4S9T ..77 ##)t/M/M8  r~c8|jj|S)zAdd a prompt to the server. Args: prompt: A Prompt instance or @prompt-decorated function to add Returns: The prompt instance that was added to the server. )r add_prompt)rrOs rwrzFastMCP.add_prompt6s##..v66r~ rrrrrrrrrc yrsr rrrrrrrrrrrs rwrOzFastMCP.promptAs r~c yrsrrs rwrOzFastMCP.promptQsr~c t|jj||||||||| | |  S|j|  S)a Decorator to register a prompt. Prompts can optionally request a Context object by adding a parameter with the Context type annotation. The context provides access to MCP capabilities like logging, progress reporting, and session information. This decorator supports multiple calling patterns: - @server.prompt (without parentheses) - @server.prompt() (with empty parentheses) - @server.prompt("custom_name") (with name as first argument) - @server.prompt(name="custom_name") (with name as keyword argument) - server.prompt(function, name="custom_name") (direct function call) Args: name_or_fn: Either a function (when used as @prompt), a string name, or None name: Optional name for the prompt (keyword-only, alternative to name_or_fn) description: Optional description of what the prompt does tags: Optional set of tags for categorizing the prompt meta: Optional meta information about the prompt Examples: ```python @server.prompt def analyze_table(table_name: str) -> list[Message]: schema = read_table_schema(table_name) return [ { "role": "user", "content": f"Analyze this schema: {schema}" } ] @server.prompt() async def analyze_with_context(table_name: str, ctx: Context) -> list[Message]: await ctx.info(f"Analyzing table {table_name}") schema = read_table_schema(table_name) return [ { "role": "user", "content": f"Analyze this schema: {schema}" } ] @server.prompt("custom_name") async def analyze_file(path: str) -> list[Message]: content = await read_file(path) return [ { "role": "user", "content": { "type": "resource", "resource": { "uri": f"file://{path}", "text": content } } } ] @server.prompt(name="custom_name") def another_prompt(data: str) -> list[Message]: return [{"role": "user", "content": data}] # Direct function call server.prompt(my_function, name="custom_name") ``` r)rrOrrs rwrOzFastMCP.promptascn##** #)+  04/M/M+  r~cddl}ddlm}|)|jdtd||}n t d|B|jdtd|r'dd lm}t||stj|}||} |rG|jD cic]\} } | t| } } } | jt| } |j| |xsd ycc} } w) a Mount another FastMCP server on this server with an optional namespace. Unlike importing (with import_server), mounting establishes a dynamic connection between servers. When a client interacts with a mounted server's objects through the parent server, requests are forwarded to the mounted server in real-time. This means changes to the mounted server are immediately reflected when accessed through the parent. When a server is mounted with a namespace: - Tools from the mounted server are accessible with namespaced names. Example: If server has a tool named "get_weather", it will be available as "namespace_get_weather". - Resources are accessible with namespaced URIs. Example: If server has a resource with URI "weather://forecast", it will be available as "weather://namespace/forecast". - Templates are accessible with namespaced URI templates. Example: If server has a template with URI "weather://location/{id}", it will be available as "weather://namespace/location/{id}". - Prompts are accessible with namespaced names. Example: If server has a prompt named "weather_prompt", it will be available as "namespace_weather_prompt". When a server is mounted without a namespace (namespace=None), its tools, resources, templates, and prompts are accessible with their original names. Multiple servers can be mounted without namespaces, and they will be tried in order until a match is found. The mounted server's lifespan is executed when the parent server starts, and its middleware chain is invoked for all operations (tool calls, resource reads, prompts). Args: server: The FastMCP server to mount. namespace: Optional namespace to use for the mounted server's objects. If None, the server's objects are accessible with their original names. as_proxy: Deprecated. Mounted servers now always have their lifespan and middleware invoked. To create a proxy server, use create_proxy() explicitly before mounting. tool_names: Optional mapping of original tool names to custom names. Use this to override namespaced names. Keys are the original tool names from the mounted server. prefix: Deprecated. Use namespace instead. rN)FastMCPProviderz=The 'prefix' parameter is deprecated, use 'namespace' insteadrrz,Cannot specify both 'prefix' and 'namespace'zas_proxy is deprecated and will be removed in a future version. Mounted servers now always have their lifespan and middleware invoked. To create a proxy server, use create_proxy() explicitly.rY)rrr)r)fastmcp.server.providers.fastmcp_providerrr]rrfastmcp.server.providers.proxyrZrras_proxyitemsrJwrap_transformrBr) rrrr tool_namesprefixrrrZrold_namenew_namers rwmountz FastMCP.mounts` M   HMMO"   "  !OPP   HMMK#  G!&,7$--f5F-V4 +5*:*:*<*<&Hh-8<<*<  ..}Z/HIH (io2>sC#c 8Kddl}|jdtddd}|jd{D]8}|r#|j d|d |j i }|j |:|jd{D]E}|r0|t|j|}|j d|i }|j|G|jd{D]<}|r'||j|} |j d | i }|j|>|jd{D]8} |r#| j d|d | j i } |j| :|j t"k7rdd lm} | d t$d|r4t&j)d|j d|j d|dyt&j)d|j d|j y777+7֭w)a Import the MCP objects from another FastMCP server into this one, optionally with a given prefix. .. deprecated:: Use :meth:`mount` instead. ``import_server`` will be removed in a future version. Note that when a server is *imported*, its objects are immediately registered to the importing server. This is a one-time operation and future changes to the imported server will not be reflected in the importing server. Server-level configurations and lifespans are not imported. When a server is imported with a prefix: - The tools are imported with prefixed names Example: If server has a tool named "get_weather", it will be available as "prefix_get_weather" - The resources are imported with prefixed URIs using the new format Example: If server has a resource with URI "weather://forecast", it will be available as "weather://prefix/forecast" - The templates are imported with prefixed URI templates using the new format Example: If server has a template with URI "weather://location/{id}", it will be available as "weather://prefix/location/{id}" - The prompts are imported with prefixed names Example: If server has a prompt named "weather_prompt", it will be available as "prefix_weather_prompt" When a server is imported without a prefix (prefix=None), its tools, resources, templates, and prompts are imported with their original names. Args: server: The FastMCP server to import prefix: Optional prefix to use for the imported server's objects. If None, objects are imported with their original names. rNz0import_server is deprecated, use mount() insteadrrrCcltj|}|r|j\}}||d|S|S)uGAdd prefix to resource URI: protocol://path → protocol://prefix/path./) URI_PATTERNmatchgroups)rCrrprotocolpaths rwadd_resource_prefixz2FastMCP.import_server..add_resource_prefixSs>%%c*E!&$"F81TF33Jr~r_)update uri_template)r]zeWhen importing from a server with a lifespan, the lifespan from the imported server will not be used.)r#categoryr[z] Imported server z with prefix '')rCr~rr~rr~)rr]rr model_copyrrrr~rCrrrrrrrrRuntimeWarningrmrg) rrrrrrr?new_urirHnew_uri_templaterOr]s rw import_serverzFastMCP.import_server#sP  >   !++---Dv&499+7N.OP MM$ . %33555H-c(,,.?H#..ug6F.G   h ' 6 %<<>>>H#6x7L7Lf#U #..*,<=/   h ' ?#//111F**6fXQv{{m;T2U*V OOF #2   / / % '   LLDII;0 ^F8STU  LL1TYYK'9&++G HQ. 6 ?2sI5HHAH H AH*H+AHHCHHHHc Fddlm} | |||||||| } |d|| gd| S)a Create a FastMCP server from an OpenAPI specification. Args: openapi_spec: OpenAPI schema as a dictionary client: Optional httpx AsyncClient for making HTTP requests. If not provided, a default client is created using the first server URL from the OpenAPI spec with a 30-second timeout. name: Name for the MCP server route_maps: Optional list of RouteMap objects defining route mappings route_map_fn: Optional callable for advanced route type mapping mcp_component_fn: Optional callable for component customization mcp_names: Optional dictionary mapping operationId to component names tags: Optional set of tags to add to all components validate_output: If True (default), tools use the output schema extracted from the OpenAPI spec for response validation. If False, a permissive schema is used instead, allowing any response structure while still returning structured JSON. **settings: Additional settings passed to FastMCP Returns: A FastMCP server with an OpenAPIProvider attached. OpenAPIProvider) openapi_specr  route_maps route_map_fnmcp_component_fn mcp_namesrvalidate_outputrrr)providers.openapir) clsrr rrrrrrrrrrs rw from_openapizFastMCP.from_openapisCJ 7,%!%-+  ? ?h??r~c ddlm} |i}|jddtjd dtj |i|} |xs |j } | |j| |||||} |d | | gd| S) af Create a FastMCP server from a FastAPI application. Args: app: FastAPI application instance name: Name for the MCP server (defaults to app.title) route_maps: Optional list of RouteMap objects defining route mappings route_map_fn: Optional callable for advanced route type mapping mcp_component_fn: Optional callable for component customization mcp_names: Optional dictionary mapping operationId to component names httpx_client_kwargs: Optional kwargs passed to httpx.AsyncClient. Use this to configure timeout and other client settings. tags: Optional set of tags to add to all components **settings: Additional settings passed to FastMCP Returns: A FastMCP server with an OpenAPIProvider attached. rrbase_urlzhttp://fastapi transport)r)rr rrrrrrr)rr setdefaultrq AsyncClient ASGITransportropenapi)rrrrrrrhttpx_client_kwargsrrrr  server_namers rw from_fastapizFastMCP.from_fastapis> 7  &"$ &&z3CD"" ))c2 !  'cii ,!%- F zFXFFr~c tjjrtjdt dt |fi|S)aCreate a FastMCP proxy server for the given backend. .. deprecated:: Use :func:`fastmcp.server.create_proxy` instead. This method will be removed in a future version. The `backend` argument can be either an existing `fastmcp.client.Client` instance or any value accepted as the `transport` argument of `fastmcp.client.Client`. This mirrors the convenience of the `fastmcp.client.Client` constructor. z{FastMCP.as_proxy() is deprecated. Use create_proxy() from fastmcp.server instead: `from fastmcp.server import create_proxy`rr)rrrrr]r create_proxy)rbackendrs rwrzFastMCP.as_proxys=6    0 0 MMT"  G0x00r~c|j}||dtjdS|d|dtjdS)N-r)rsecrets token_hex)rr class_names rwrzFastMCP.generate_namesP\\ < \7#4#4Q#7"89 9 \4&'*;*;A*>)?@ @r~)NN)*r str | Nonerrrrrrrlist[mcp.types.Icon] | NonerzAuthProvider | NonerzSequence[Middleware] | NonerzSequence[Provider] | NonerzSequence[Transform] | Nonerz"LifespanCallable | Lifespan | Nonerz*Sequence[Tool | Callable[..., Any]] | NonerzDuplicateBehavior | Noner bool | Nonerboolrrrz int | NonerrrzAsyncKeyValue | NonerzSamplingHandler | Nonerz$Literal['always', 'fallback'] | Noner{r)rr~)rr)rrrNone)rzlist[mcp.types.Icon])rr<)rzMiddlewareContext[Any]rz2Callable[[MiddlewareContext[Any]], Awaitable[Any]]rr)rr7rr)rr=rr~rr)rzSequence[FastMCPComponent])r rCrr)rr~rrJrr)rr~rr)rrrzSequence[Tool]rs)rr~rVersionSpec | Nonerz Tool | None)rrrzSequence[Resource])rCr~rrrzResource | None)rrrzSequence[ResourceTemplate])rCr~rrrzResourceTemplate | None)rrrzSequence[Prompt])rr~rrrz Prompt | None) rr~rXdict[str, Any] | NonerrrrrUrrrI) rr~rXrrrrrrUr@rmcp.types.CreateTaskResult) rr~rXrrrrrrUTaskMeta | Nonerz'ToolResult | mcp.types.CreateTaskResult) rCr~rrrrrUrrr,) rCr~rrrrrUr@rr) rCr~rrrrrUrrz+ResourceResult | mcp.types.CreateTaskResult) rr~rXrrrrrrUrrr*) rr~rXrrrrrrUrrz)PromptResult | mcp.types.CreateTaskResult)rzTool | Callable[..., Any]rrH)rr~rrrr) rr[rrrstr | int | Nonerrrrrrrset[str] | Nonerdict[str, Any] | NotSetT | Noner'ToolAnnotations | dict[str, Any] | Nonerlist[str] | Nonerrr(AppConfig | dict[str, Any] | bool | Nonerbool | TaskConfig | Noner float | Noner"AuthCheck | list[AuthCheck] | Nonerr[) rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrCallable[[F], F]) rstr | AnyFunction | NonerrrrrrrrrrrrrrrrrrrrrrrrrrrrrztCallable[[AnyFunction], FunctionTool] | FunctionTool | partial[Callable[[AnyFunction], FunctionTool] | FunctionTool])r?zResource | Callable[..., Any]rzResource | ResourceTemplate)rHr-rr-)rCr~rrrrrrrrrrrrrrrz#Annotations | dict[str, Any] | Nonerrrrrrrrrr)rOzPrompt | Callable[..., Any]rr()rr[rrrrrrrrrrrrrrrrrrrr[)rrrrrrrrrrrrrrrrrrrrrr)rrrrrrrrrrrrrrrrrrrrrz|Callable[[AnyFunction], FunctionPrompt] | FunctionPrompt | partial[Callable[[AnyFunction], FunctionPrompt] | FunctionPrompt])NNNN) rrrrrrrdict[str, str] | Nonerrrr)rrrrrr)NzOpenAPI ServerNNNNNT)rdict[str, Any]r zhttpx.AsyncClient | Nonerr~rlist[RouteMap] | NonerOpenAPIRouteMapFn | NonerOpenAPIComponentFn | Nonerrrrrrrrrr )NNNNNNN)rrrrrrrrrr rrrrrrrrrr )r}Client[ClientTransportT] | ClientTransport | FastMCP[Any] | FastMCP1Server | AnyUrl | Path | MCPConfig | dict[str, Any] | strrrrrZ)rrrr~)5rrrrrpropertyrrsetterrrrrrrrrrrrrr7r:rrBrErrJrLrrQrSrrYrzrrrrNrrrr?rrOrr classmethodrrrr __classcell__)rs@rwrrsd #'@ #"&-1$(26/3157;<@15*.$(/3%)!4837JN-@ @ !@  @  @ +@ "@ 0@ -@ /@ 5@ :@ /@ (@ "!@ ""-#@ $#%@ &'@ (2)@ *1+@ ,$H-@ ./@ D7%%--..((,,00  $ $ $' $F $ $+DF<, :+(GG.AG G" :>%P8<"4 @8<"4 6)-'!%' 'T7;!3 @7;!3 4)-)!%) #)X7;!3 @7;!3 2<@%P8<"4 @8<"4 2,0 '+#) $    ,0) '+# )))) $ )  )) $)),0]P '+#%)]P]P)]P $ ]P  ]P#]P 1]P~ '+#  $       '+# ) )$ )  )  ) $))'+#%) CW CW$ CW  CW # CW 5CWJ,0 '+#) $    ,0) '+# )))) $ )  )) $)),0JV '+#%)JVJV)JV $ JV  JV#JV 3JVX 3:  $( "&-1 $9??C)-&*8<)- $37#  "    +7='$6' !"1#$ %("& $( "&-1 $9??C)-&*8<)- $37#  "    +7='$6' !"1#$ %,04a $( "&-1 $9??C)-&*8<)- $37#a,a a " a  a a+aa7a=a'a$a6a'a !a"1#a& H'aF ;5 ; $ ; ; $( "&-1 $ $;?&*8<)-37u u u " u  u u+uuu9u$u6u'u1u !un 7  $( "&-1 $&*)-37    "     +  $ ' 1    "&  $( "&-1 $&*)-37    "     +  $ ' 1    "04b  $( "&-1 $&*)-37b ,b  b " b  b  b +b b $b 'b 1b  Lb N!% $,0! \?(\?\? \? * \?  \? \?B"aI(aIaI  aIF,0$,0156:+/ $ $0@$0@)0@ 0@ * 0@ / 0@40@)0@0@0@0@ 0@0@d ,0156:+/59 $4G 4G4G* 4G / 4G 4 4G)4G34G4G4G 4G4Gl"1 "1"1 "1"1HAAr~rc 6ddlm}m}||}|dd|i|S)aCreate a FastMCP proxy server for the given target. This is the recommended way to create a proxy server. For lower-level control, use `FastMCPProxy` or `ProxyProvider` directly from `fastmcp.server.providers.proxy`. Args: target: The backend to proxy to. Can be: - A Client instance (connected or disconnected) - A ClientTransport - A FastMCP server instance - A URL string or AnyUrl - A Path to a server script - An MCPConfig or dict **settings: Additional settings passed to FastMCPProxy (name, etc.) Returns: A FastMCPProxy server that proxies to the target. Example: ```python from fastmcp.server import create_proxy # Create a proxy to a remote server proxy = create_proxy("http://remote-server/mcp") # Create a proxy to another FastMCP server proxy = create_proxy(other_server) ``` r)rZ_create_client_factoryclient_factoryr)rrZr)targetrrZrrs rwrr$s1V ,F3N  %   r~)r{rrr)rztuple[bool, Any])rrrzAsyncIterator[Any])rrrzYCallable[[LowLevelServer[LifespanResultT]], AbstractAsyncContextManager[LifespanResultT]])rr rrrrZ)r __future__rrrerrcollections.abcrrrr contextlibrr dataclassesr functoolsr pathlibr typingr rrrrrrrq mcp.typesr/key_value.aio.adapters.pydanticrkey_value.aio.protocolsrkey_value.aio.stores.memoryrmcp.server.lowlevel.serverrmcp.shared.exceptionsrrrrrpydanticrrrostarlette.routingrtyping_extensionsr rfastmcp.serverfastmcp.exceptionsr!r"r#r$r%r&fastmcp.mcp_configr'fastmcp.promptsr(fastmcp.prompts.function_promptr)fastmcp.prompts.promptr*fastmcp.resources.resourcer+r,fastmcp.resources.templater-fastmcp.server.appsr.r/r0fastmcp.server.authr1r2r3r4fastmcp.server.lifespanr5fastmcp.server.low_levelr6fastmcp.server.middlewarer7r8fastmcp.server.mixinsr9r:r;fastmcp.server.providersr<r="fastmcp.server.providers.aggregater>fastmcp.server.tasks.configr?r@fastmcp.server.telemetryrAfastmcp.server.transformsrBrC$fastmcp.server.transforms.visibilityrDrEfastmcp.settingsrFDuplicateBehaviorSettingfastmcp.tools.function_toolrGfastmcp.tools.toolrHrIfastmcp.tools.tool_transformrJfastmcp.utilities.componentsrKfastmcp.utilities.loggingrLfastmcp.utilities.typesrMrNrOfastmcp.utilities.versionsrPfastmcp.clientrQfastmcp.client.clientrRfastmcp.client.samplingrSfastmcp.client.transportsrTrU fastmcp.server.providers.openapirVOpenAPIComponentFnrWrXOpenAPIRouteMapFnrrZrrmr[rprr} Transportcompilerrrrrrrrrr~rwrJs;"   PPP ;136* ?'")":/?7 VU,3CSS<@<0VJ4/<90EE%47KR9P; H  CxS)*@A# E# E#]#/ # u # p #s# !#T#8#<#:#A#Y#O# g!#(   = > bjj-.  "=o"NN '&    ,0! HA O HA`:4 444r~