kKj jUdZddlmZddlZddlZddlZddlZddlZddlm 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;ddlZ>m?Z?m@Z@mAZAmBZBmCZCm0Z0ddlDmEZEddlFmGZGddlHmIZIddlJmKZKddlLmMZMmNZNddlOmPZPddlQmRZRmSZSmTZTmUZUddlVmWZWddlXmYZYddlZm[Z[m\Z\m]Z]dd l^m_Z_m`Z`maZadd!lbmcZcmdZddd"lemfZfdd#lgmhZhmiZidd$ljmkZkdd%llmmZmmnZndd&lompZpmqZqdd'lrmsZtdd(lumvZvmwZwdd)lxmyZydd*lzm{Z{dd+l|m}Z}m~Z~dd,lmZdd-lmZmZmZdd.lmZmZer2dd/lmZdd0lmZdd1lmZdd2lmZmZdd3lmZdd4lmZdd5lmZdd6lmZeeZ dmd7ZGd8d9ej8Zej<d:j?eed;e dZsid?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdRdTdRdUdVdWdXdYdZd[d\Zd]ed^<dnd_Zed`ZejJdaZe dbge e'fZdodcZdpddZdpdeZedqdfZ drdgZGdhdieZGdjdkefe_e`eaee'Z dsdlZy)tz5FastMCP - A more ergonomic interface for MCP servers.) annotationsN) AsyncIteratorCallableSequence)AbstractAsyncContextManagerasynccontextmanager)replace)partial)Path) TYPE_CHECKINGAnyGenericLiteralTypeVarcastoverload)PydanticAdapter) AsyncKeyValue) MemoryStore)LifespanResultT)McpError) Annotations AnyFunctionCallToolRequestParamsToolAnnotations)AnyUrl)ValidationError) BaseRoute)Self) AppConfigapp_config_to_meta_dictresolve_ui_mime_type)AuthorizationErrorFastMCPDeprecationWarning FastMCPError NotFoundError PromptError ResourceError ToolErrorr) MCPConfig)Prompt) PromptResult)FunctionPrompt)ResourceResourceResult)ResourceTemplate) AuthCheck AuthContext AuthProviderrun_auth_checks)Lifespan)LowLevelServer)CallNext MiddlewareMiddlewareContext) LifespanMixinMCPOperationsMixinTransportMixin) LocalProviderProvider)AggregateProvider) TaskConfigTaskMeta) server_span) ToolTransform Transform)apply_session_transforms is_enabled)DuplicateBehavior)Tool ToolResult) FunctionTool)ToolTransformConfig)FastMCPComponent_coerce_version) get_logger)FastMCPBaseModelNotSetNotSetT) VersionSpecversion_sort_key)Client)FastMCP1Server)SamplingHandler)ClientTransportClientTransportT) ComponentFn)RouteMap) RouteMapFn FastMCPProxycx|y|j%|j|j |j}nG|j|j|jdjDcic] \}}||| }}}|sytj j jjdd|iiScc}}w)N)gtelteqfastmcpversion) rar_r`itemsmcptypes RequestParamsMetamodel_validate)rc version_valuekeyvalues f/Users/ahmed/devFolder/Ultron/claude-voice/.venv/lib/python3.12/site-packages/fastmcp/server/server.py_version_request_metarnhszz'++"5'**:L.5jj {{jjjjeg   U  J    99 " " ' ' 6 6 Y ./  s*B6ceZdZddZy)_SuppressUnlistedToolWarningc&d|jvS)Nznot listed, no validation) getMessage)selfrecords rmfilterz#_SuppressUnlistedToolWarning.filters*&2C2C2EEEN)rtzlogging.LogRecordreturnbool)__name__ __module__ __qualname__rurvrmrprpsFrvrpzmcp.server.lowlevel.serverF.)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 rm z(_check_removed_kwargs..sF_X^STtAwX^sN)r TypeErrorjoin)kwargsrks rm_check_removed_kwargsrsi / !/uC8L7MN  _`` calls. Tools without an explicit visibility declaration are NOT app-callable — they must be reached by their display name through the normal transform-aware resolution path. This is the inverse of the "everything is dot-callable" trap: the hashed-name path is an opt-in mechanism for FastMCPApp backend tools, not a general bypass for arbitrary tools. Frrr)rrrrr)rrrrs rm_is_app_visiblersS 99D  $B b$  %J j$ ' J rvcKiyw)zDefault lifespan context manager that does nothing. Args: server: The server instance this lifespan is managing Returns: An empty dictionary as the lifespan result. Nr|)servers rmdefault_lifespanrs  Hs c.t dfd }|S)NcKjturiyjs tdjyw)NaFastMCP server has a lifespan defined but no lifespan result is set, which means the server's context manager was not entered. Are you running the server in a way that supports lifespans? If so, please file an issue at https://github.com/PrefectHQ/fastmcp/issues.) _lifespanr_lifespan_result_set RuntimeError_lifespan_result)low_level_serverfastmcp_servers rmwrapz_lifespan_proxy..wrap!sJ  # #'7 7H 22\  ---sAA)rzLowLevelServer[LifespanResultT]rwzAsyncIterator[LifespanResultT])r)rrs` rm_lifespan_proxyrs.  .9 . ' . . KrvceZdZUdZded<y) StateValuez(Wrapper for stored context state values.r rlN)ryrzr{__doc____annotations__r|rvrmrr4s 2 Jrvrc`eZdZ dDddddddddddddddddddddd dEfdZdFdZedFdZedGdZejdHdZedGd Z edGd Z edId Z edJd Z dKd Z dLdZdddMfdZdNdZdOfd ZdPdZ dQdZdRdZdddSfdZ dT dUfd Z dT dUfd Zdd dVfdZ dT dWfd Z dT dWfd Zdd dXfdZ dT dYfd Z dT dYfd ZdddZfd!Z dT d[fd" Z dT d[fd# Z e! dTdddd$ d\d%Z"e! dTddd& d]d'Z" dTdddd$ d^d(Z"e!dddd$ d_d)Z#e!ddd& d`d*Z#dddd$ dad+Z#e! dTdddd$ dbd,Z$e! dTddd& d]d-Z$ dTdddd$ dcd.Z$ddd/Z%dTded0Z&e!dddddde'ddddddddd1 dfd2Z(e! dTdddddde'ddddddddd1 dgd3Z( dTdddddde'ddddddddd1 dhd4Z( did5Z)djd6Z*ddddddddddddd7 dkd8Z+dld9Z,e!dddddddddd: dmd;Z-e! dTdddddddddd: dnd<Z- dTdddddddddd: dod=Z- dp dqd>Z. dT drd?Z/e0 ds dtd@Z1e0 du dvdAZ2e0 dwdBZ3e0dTdxdCZ4xZ5S)yFastMCPNT)rc website_urliconsauth middleware providers transformslifespantools on_duplicatemask_error_detailsdereference_schemasstrict_input_validationlist_page_sizetaskssession_state_storesampling_handlersampling_handler_behaviorclient_log_levelexperimental_capabilitiesc t|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|_d|_t?j@|_!t?jD|_#tIt2||xs|jKtM|xst"jN|||tQ| |_)||_*| r=| D]8}tW|tXstYjZ|}|j]|:||nt"j$j^|_/||nt"j$j`|_0|xsi|_1te|xsg|_3|r&dd l4m5}|jfjm||jo||_8|xsd |_9y) NrF fastmcp_state) key_valuepydantic_modeldefault_collection)rrz)list_page_size must be a positive integer)r)rbnamerc instructionsrrr)DereferenceRefsMiddlewarefallback):rsuper__init__ _on_duplicate_support_tasks_by_default_docket_worker_additional_http_routesr_state_storagerr _state_storer=_local_provider add_provider add_transformrbsettingsr_mask_error_details ValueError_list_page_sizerLifespanCallablerrrrr_lifespan_ref_countasyncioLock_lifespan_lockEvent_startedr6 generate_namerM __version__r _mcp_serverrrrH from_functionadd_toolrrrrr%fastmcp.server.middleware.dereferencerappend_setup_handlersrr)rsrrrcrrrrrrrrrrrrrrrrrrrrptrr __class__s rmrzFastMCP.__init__As6 f% 7C7Mv9>8Iuu&  8:$.A-QKM9H9T))%.: /<++/  $../bA   a !!r!A   q !" "- !!44    %.A*=HI I+9  @D 18ADN""2?"CEUVDN8<*/!() ,3LLN'.}} BP B -++-#G,C0C0C%#$D9 B *. !$---d3D d#'2 $!!99 $ + !!22  & + &-11Ar,B   OO " "#<#> ? 8H % 3 &rvcLt|jd|jdS)N())typeryrrss rm__repr__zFastMCP.__repr__s$t*%%&a }A66rvc.|jjSr)rrr s rmrz FastMCP.names$$$rvc.|jjSrrrr s rmrzFastMCP.instructionss,,,rvc&||j_yrr)rsrls rmrzFastMCP.instructionss(-%rvc.|jjSr)rrcr s rmrczFastMCP.versions'''rvc.|jjSr)rrr s rmrzFastMCP.website_urls+++rvcp|jjgSt|jjSr)rrrr s rmrz FastMCP.iconss0    ! ! )I((../ /rvc|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") )rr s rmlocal_providerzFastMCP.local_providers###rvcK|}t|jD]/}|}||f dd}ttttf|}1||d{S7w)z)Builds and executes the middleware chain.c0K|||d{S7wrr|)contextmw call_nexts rmwrappedz(FastMCP._run_middleware..wrappeds  3333s N)rMiddlewareContext[Any]rr8rCallNext[Any, Any]rwr )reversedrrr7r )rsrrchainr next_chainrs rm_run_middlewarezFastMCP._run_middlewares 4??+B-2J"$0: 4/ 4 4. 4  4#s(+W5E,7^###sAAAAc:|jj|yr)rr)rsrs rmadd_middlewarezFastMCP.add_middlewares z*rv 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" r'N)rr)rsproviderr(rs rmrzFastMCP.add_providers X;rvc\ddlm}m}|Dcgc]}||r||n|c}Scc}w)uReplace placeholder Prefab URIs with per-tool hashed ones. For each tool whose ``meta.ui.resourceUri`` is the placeholder, reads the tool's stored hash from ``meta.fastmcp._tool_hash`` and rewrites the URI to the per-tool form. Also strips CSP from tool meta (it belongs on the resource). Produces ``model_copy`` views — originals are untouched. r)_is_prefab_toolrewrite_tool_meta_for_wire))fastmcp.server.providers.prefab_synthesisr,r-)rsrr,r-rs rm_rewrite_prefab_uriszFastMCP._rewrite_prefab_uris"s? QV PU1_Q-? &q )Q FPU   s)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.r0r+r list_toolslist_resourceslist_resource_templates list_prompts) rs componentscr resources templatesprompts transformrs rmr1zFastMCP.get_tasks:sC 1 334 '>Jq*Q*=J> *F 1jH.EQ F *N 1j |j/| Q|cdddcdddd{S7g7777cc}w7G#t,$rYwxYw7(#1swYnxYwdddd{7y#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. rbNz tools/list)methodclientrequestmessagesourcer rNfastmcp_contextc(jdSNFrJ)r2rrss rmz$FastMCP.list_tools..sdooUo.Srvrrrr&token component)rbrrContextr9rerfListToolsRequestr#rBrrrr2rErFrr/rrr2r4r#r) rsrKctx mw_contextrr skip_authr[ authorizedrrs ` rmr2zFastMCP.list_toolss>>))11$1??3.II66l6K#"'$'  "11&S2@??\<FBO57#5#7786u==$)WEqZ]CSTUCVEW11%8#4#6 5)+ !D$)>)F%)8C)H#H#H ($I%%d+""3PO@??@$8=W$I1%$%K@PO@????s/G2FG2A GFG G2F G2G0F?F# F?F%F?'F'8 F'F'AF? F.$F, %F.)F?? G G2F=G2G G2#F?%F?'F?,F.. F: 7F?9F: :F?=G2?G G G2GG2G/#G& $G/+G2cKt|||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. NrZ)r _get_toolrrr2r4r#)rsrrcrrar[r_rs rmrdzFastMCP._get_toolsW&tW55 <-. 5TYY2ET:C ,TYY<<<=  t 6=%  KA?A,/A?A0!A."A0&A?(A?.A00 A<9A?;A<<A?cKt |||d{}|yt|gd{}|r!t|drt |ds|dS|yt |d{Dcgc]}|j |k(s|}}tt|d{}|Dcgc]}t|st |r|}}t\}} g} |D]O}|s:|j.t| |} t|j| d{s> | j|Q| syt| tS7/77cc}w7cc}w7A#t$rYwxYww)a_Get 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. When the highest version is disabled and no explicit version was requested, falls back to the next-highest enabled version. Args: name: The tool name. version: Version filter (None returns highest version). Returns: The tool if found and enabled, None otherwise. NrrZrk)rget_toolrErFrr2rrrrr2r4r#rmaxrS) rsrrcrrr all_toolsenabledrar[rbr_rs rmrhzFastMCP.get_toolst&W%dG44 </v66 Za)2B582L8O  &+g&8&: : :M :1affnQ : M7 BBC 'Ui:a=AQRSAT1iU,. 5!# A!3!;!0!=== >   a :#344C5 7!;MBU>)sE+EE+E ;E+*E +E+1EE E+E E+,E= E E 1E+?EEE*E+ E+ E+E+E+E E(%E+'E((E+cKtjjj4d{}|r?t iddd|}j |fdd{cdddd{St ddjd d 5tt )d{}t|d{}|Dcgc]}t|s|}}d d l m}|j|d{t!\}}g} |D]O} |s:| j".t%|| } t'| j"|d{s> | j+| Q| cdddcdddd{S7Q7$777cc}w77I#t($rYwxYw7*#1swYnxYwdddd{7y#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. rMNrOrPzresources/listrQc(jdSrV)r3rWs rmrXz(FastMCP.list_resources..%sd.A.AQV.A.WrvrYresourcer&r)synthesize_prefab_resourcesrZ)rbrrr]r9r#rBrrrr3rErFr.roextendrrr2r4r#r) rsrKr_r`r8rrorar[rbrnrs ` rmr3zFastMCP.list_resourcess>>))11$1??3.#"+$'  "11&W2@?? "2DIIz2!uw'='?!?@ ":9"EE (1C 1Z]Q C   'B4'H!HI#4#6 5-/ )H$)B)J%)8)L#L#L ($M%%h/!*"9@??@&"@EC"I$M1%$%Q@@????s/GFG,G #F$G ' G3F 4G9G F+)F *F+FF+ FFF+<F =7F+5FF FF+) G 2 G>F)?GG  G F+F+F+F F& #F+%F& &F+)G+F4 0G 7 GGG GG GGcKt|||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. NrZ)r _get_resourcerrr2r4r#)rsurircrnrar[r_rs rmrszFastMCP._get_resourceGs.sG<<  -. 5X]]6EX>C ,X]]C@@@A x=A%  recKt |||d{}|yt|gd{}|rt|dr|dS|yt |d{Dcgc]}t |j |k(s|}}tt|d{}|Dcgc]}t|s|}}t\}} g} |D]O}|s:|j.t| |} t|j| d{s> | j|Q| syt| tS77 7cc}w7cc}w7A#t$rYwxYww)a"Get a resource by URI, filtering disabled resources. Overrides Provider.get_resource() to add visibility filtering after all transforms (including session-level) have been applied. When the highest version is disabled and no explicit version was requested, falls back to the next-highest enabled version. Args: uri: The resource URI. version: Version filter (None returns highest version). Returns: The resource if found and enabled, None otherwise. NrrZrg)r get_resourcerErFr3strrtrrrr2r4r#rrirS) rsrtrcrnr8rq all_resourcesrkrar[rbr_rs rmrvzFastMCP.get_resourcefse$-c7;;  3H:>> IaL1Q<   */'*@*B$B$BX$Bqc!%%jTWFW$B X#;M#JJK +=mz!}1m=,. 5%' A!3!;!0!=== >   a :#344=< ?%CXJ=>)sED5ED8-ED;E#D=D=EE E'E8E<1E.E E E  *E8E;E=EE E  EEEEcnKtjjj4d{}|r?t iddd|}j |fdd{cdddd{St ddjd d 5tt )d{}t|d{}|Dcgc]}t|s|}}t\}}g}|D]O} |s:| j.t|| } t!| j|d{s> |j%| Q|cdddcdddd{S7,7777cc}w7E#t"$rYwxYw7&#1swYnxYwdddd{7y#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. rMNrOrPzresources/templates/listrQc(jdSrV)r4rWs rmrXz1FastMCP.list_resource_templates..sd.J.J',/K/rvrYresource_templater&rZ)rbrrr]r9r#rBrrrr4rErFrrr2r4r#r) rsrKr_r`r9rrar[rbtemplaters ` rmr4zFastMCP.list_resource_templatess>>))11$1??3.#"5$'  "11&2@??"** # !uw'F'H!HI ":9"EE (1C 1Z]Q C#4#6 557 )H$)B)J%)8)L#L#L ($M%%h/!*"/#@??@2"IEC$M1%$%K@"#@????/F5EF5,F #E"$F ' F53E$4F59F F)E& *FE(F E*E*1FE1)E/ *E1.F F  F5FF5"F $F5&F(F*F/E11 E= :F<E= =FF5F F  F5FF5 F2&F) 'F2.F5cKt|||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. NrZ)r_get_resource_templaterrr2r4r#)rsrtrcr|rar[r_rs rmrzFastMCP._get_resource_templates7WEE  -. 5X]]6EX>C ,X]]C@@@A xFA%  recKt |||d{}|yt|gd{}|rt|dr|dS|yt |d{Dcgc]}|j ||}}t t|d{}|Dcgc]}t|s|}}t\}} g} |D]O}|s:|j.t| |} t|j| d{s> | j|Q| syt| tS777cc}w7cc}w7A#t$rYwxYww)a4Get 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. When the highest version is disabled and no explicit version was requested, falls back to the next-highest enabled version. Args: uri: The template URI. version: Version filter (None returns highest version). Returns: The template if found and enabled, None otherwise. NrrZrg)rget_resource_templaterErFr4matchesrrrr2r4r#rrirS) rsrtrcr|r9r all_templatesrkrar[rbr_rs rmrzFastMCP.get_resource_templatesw$6sGDD  3H:>> IaL1Q<   !7:<<< <yy~) <  #;M#JJK +=mz!}1m=,. 5-/ A!3!;!0!=== >   a :#344EE ?= K=>)sED-ED0-ED3E#D5=ED: ED<0D<41E&E?EE*E0E3E5E<EE E EEEcnKtjjj4d{}|r?t iddd|}j |fdd{cdddd{St ddjd d 5tt )d{}t|d{}|Dcgc]}t|s|}}t\}}g}|D]O} |s:| j.t|| } t!| j|d{s> |j%| Q|cdddcdddd{S7,7777cc}w7E#t"$rYwxYw7&#1swYnxYwdddd{7y#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. rMNrOrPz prompts/listrQc(jdSrV)r5rWs rmrXz&FastMCP.list_prompts..2sd.?.?u.?.UrvrYpromptr&rZ)rbrrr]r9r#rBrrrr5rErFrrr2r4r#r) rsrKr_r`r:rrar[rbrrs ` rmr5zFastMCP.list_prompts s>>))11$1??3.#")$'  "11&U2@??^^TYYRTUUW%9%;;< 8 AA&-?gA1g?#4#6 5+- %F$)@)H%)8c)J#J#J ($K%%f-&"#VU@??@" <A?$K1%$%;@VU@????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. NrZ)r _get_promptrrr2r4r#)rsrrcrrar[r_rs rmrzFastMCP._get_promptIsw*499 >-. 5V[[4EV>>?  v :?%  recKt |||d{}|yt|gd{}|rt|dr|dS|yt |d{Dcgc]}|j |k(s|}}t t|d{}|Dcgc]}t|s|}}t\}} g} |D]O}|s:|j.t| |} t|j| d{s> | j|Q| syt| tS777cc}w7cc}w7A#t$rYwxYww)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. When the highest version is disabled and no explicit version was requested, falls back to the next-highest enabled version. Args: name: The prompt name. version: Version filter (None returns highest version). Returns: The prompt if found and enabled, None otherwise. NrrZrg)r get_promptrErFr5rrrrr2r4r#rrirS) rsrrcrr:r all_promptsrkrar[rbr_rs rmrzFastMCP.get_prompths]$w)$88 >1&:: z'!*-1:   (-(<(>">">Q">Q!&&D.q"> Q!9+!FFG );kZ]1k;,. 5#% A!3!;!0!=== >   a :#344=9 ;#?QF;>)sED,ED/-ED2E#D48D4<ED9 ED;/D;31E%E>E?E*E/E2E4E;EE E E EErcrK task_metac Kywrr|rsr argumentsrcrKrs rm call_toolzFastMCP.call_tools )rcrKc Kywrr|rs rmrzFastMCP.call_tool &)rc Kddlm}tjjj 4d{}|rut ttjj||xsitddd| }j|fd  d{cdddd{Std |djd ||5} j|d{} | ||} | w| \} } j| | d{} | Vt!\}}|sG| j"; t%|| }t'| j"|d{st)d| | t)d|| j-| j/#j0t3| j4 | j7|xsid{cdddcdddd{S77d7W777#t*$rt)d|dwxYw7J73#t8$rV}|j:}t=|t>r|jAdn tC|}tDjGd||d}~wtH$r+}tDjK|jLd|dd}~wt>$r-}tDjGd||jAdd}~wtN$r}tDjQd|t=|tRjTr%|jVjXdk(r t[d|t=|tRj\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 r)parse_hashed_backend_namerMNrr_metarOrPz tools/callrQcj|jj|jjxsidSNFr)rrRrrrrsrrcs rmrXz#FastMCP.call_tool..s;dnn,,117R '',"+ /=/rvrYz tools/call r)rDrcrZzUnknown tool: fn_keyrF) include_urlz!Invalid arguments for tool %r: %szError calling tool exc_info0Rate limited by upstream API, please retry later(Upstream request timed out, please retry: )0#fastmcp.server.providers.addressingrrbrrr]r9rrerfrnr#rBrrhget_tool_by_hashrrr2r4r&r#set_attributesget_span_attributesrr rk_runr __cause__rPydanticValidationErrorerrorsrwloggerwarningr%logr Exception exceptionhttpxHTTPStatusErrorresponse status_coder)TimeoutExceptionr)rsrrrcrKrrr_r`spanrhasheddigest local_namerar[auth_ctxecausedetails` ` ` rmrzFastMCP.call_toolsH >>))11$1??3./DEII;;!"+/r3G<< $"'$'  "11&2  @??2dV$  *.--g-*N$N <6t?(Y-=-=-E ' $(( CI/P!%9?i!PPO3@?? @D%O O,V'9!0*7*8(A+&+/%0!0QA@B'  KKE&e-DE  7 V NN#FfU#JJ ':4(%Ce. NN;U3  P$$':4(%CD"!U%:%:;::11S8"+ R##$%"!U%;%;<'F !//'*=dX(FGQN#&9$A3$GHaO!PK3@????sD5O"HO"A"O  H!O $ O"0H1O"6O N/+H ,*N/H !N/9&HH H2AN/H1"H-#H1& O / O";H/<O"O O" N/ N/HH**N/-H1/O"1 N,:AJ  N,&J== N, (K11 N,=B*N''N,,N//N8 4O ; O"O O" OO OO"c Kywrr|rsrtrcrKrs rm read_resourcezFastMCP.read_resourcePs rc Kywrr|rs rmrzFastMCP.read_resourceZs &)rc  Ktjjj4d{}|rtt |}t t jj|tddd|}j|fd d{cdddd{Stddjd || 5}d d l m} | |d{} | S|j| j!| j#d{cdddcdddd{Sj%|d{} | y|j| j!#j&t)| j* | j#d{cdddcdddd{SjK|d{} | !tMd|tMd|d|j| j!| jO|}|J#j&t)| j* | j#||d{cdddcdddd{S7g77777y7`77#t,$r+} t.j1| j2d|dd} ~ wt4$rt.j7d|t8$r} t.j7d|t;| t<j>r%| j@jBdk(r tEd| t;| t<jFr tEd| jHrtEd|| tEd|d| | d} ~ wwxYw77J74#t,$r+} t.j1| j2d|dd} ~ wt4$rt.j7d|t8$r} t.j7d|t;| t<j>r%| j@jBdk(r tEd| t;| t<jFr tEd| jHrtEd|| tEd|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 rMN)rtrrOrPzresources/readrQchjt|jjdSr)rrwrRrtrs rmrXz'FastMCP.read_resource..s1d.@.@GOO//0 '',"+ /A/rvrYrn) resource_urir)!synthesize_prefab_resource_by_urirrrzError reading resource TrrrrrzUnknown resource: version )(rbrrr]rr9rerfReadResourceRequestParamsrnr#rBrr.rrr_readrvrr rkr%rrrrrrrrrrrr(rrrr&r)rsrtrcrKrr_ uri_paramr`rr synthesizedrnrr|paramss` ` ` rmrzFastMCP.read_resourceds'J>>))11$1??3"3K .II??%3G<@$"+$'  "11&2@??0    %FdC$PP *'' (G(G(IJ!,!2!2Y!2!GG%1@??Z"&!2!23!2!HH'''(D(D(FG ,1A1A1I$+Ihll$K !%-^^i^%HH71@??h"&!;!;C!;!QQ#+.@,HII',SG9WKH##H$@$@$BC!))#.)))(Y-=-=-E ' (,, GIW!)Vy!QQS1@??@NQHU@ZI Ig@h( KK5cW=%)# #((+B3')JK$!((+B3')JK%a)>)>? zz55<&3$V'"'(!)&a)?)?@"/ J##$% 33"/"9# A##$%,5cWBqcB !#!,RRC@D$JJ '>sg%FQU$$'>sg%FG W$$'>sg%FG!!U%:%:;::11S8"/ R##$%"!U%;%;<+F !//+.EcW,MNTUU'*A#1#(NOUVVWe1@????s/T JT A!S8JS8 T )J!*T /S8 SJ$:SJ'S S8% T 1J*2T 7S J-A SJ5.J0/J52 S8; T J3T  S#O$BS%O <O=O  S8 T O T S8!T $S'S*T -S0J53T 5 O>&K$$-OB*N;;OSO  T  S&O;;-S(B*SSSS# S8& T 1S42T 8T >T ?T T c Kywrr|rs rm render_promptzFastMCP.render_prompts rc Kywrr|rs rmrzFastMCP.render_promptrrc Ktjjj4d{}|rjt t j j||tddd|}j|fd d{cdddd{Std |djd || 5}j| d{} | td||j| j#j t#| j$ | j'|d{cdddcdddd{S757777'7#t($r+} t*j-| j.d|dd} ~ wt0$rt*j3d|t4$rJ} t*j3d|j6rt9d|| t9d|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 rMNrrOrPz prompts/getrQcj|jj|jjdSr)rrRrrrs rmrXz'FastMCP.render_prompt..Is9d.@.@,,11 '',"+ /A/rvrYz prompts/get r) prompt_namerzUnknown prompt: rrzError rendering prompt Trr)rbrrr]r9rerfGetPromptRequestParamsrnr#rBrrr&rrrr rk_renderr%rrrrrrrr') rsrrrcrKrr_r`rrrs ` ` ` rmrzFastMCP.render_promptsS@>>))11$1??3.II<<!"+3G<= $"($'  "11&2  @??4tf%  #tWEE>'*:4((CDD##F$>$>$@A(Y-=-=-E ' &** EIV!' Y!OO5@?? @DFPS@T$JJ '>th%GRV$$'>th%GH V$$'>th%GH//),CD8*LMSTT%(?xr!&MNTUU V15@????s/IE)IAH=E,H= IE. I%H=HE0AH4E6 E2 E6 H= I#E4$I,H=.I0H2E64I6 H?&F%%-HAHHHH( $H=+ I6H97I=II I Ic8|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)rsrs rmrzFastMCP.add_toolrs##,,T22rvctjjrtjdt 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.r?r@NzTool z not foundr) rbrrBrCrr$r remove_toolKeyErrorr&)rsrrcs rmrzFastMCP.remove_tools    0 0 MM@)      , ,T7 ; #eD8:$>?TIxy :>  s A/B)rrctitle descriptionrtags output_schemar exclude_argsrrtasktimeoutr run_in_threadcyrr|rs name_or_fnrrcrrrrrrrrrrrrrs rmrz FastMCP.tools( rvcyrr|rs rmrz FastMCP.tools(rvc| +| 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") ``` FTr)rrcrrrrrrrrrrrr)rr!rrr)rsrrrcrrrrrrrrrrrrrresults rmrz FastMCP.toolsR ?s%/!%4:2Dd{!T 4S9T %%** #'#%)t/M/M'+ $ rvc8|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)rsrns rmrzFastMCP.add_resource.s##00::rvc8|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)rsr|s rmrzFastMCP.add_template;s##00::rv) rrcrrr 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) rrcrrrrrrrrr) rrwrr"r rrrrr!rrnr)rsrtrrcrrrrrrrrrrinner_decorators rmrnzFastMCP.resourceFsJ#s#< )i8  c9 %+ K ~~) Y ?s%/!%4:2Dd{!T 4S9T ..77 ##)t/M/M8  rvc8|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)rsrs rmrzFastMCP.add_prompts##..v66rv rrcrrrrrrrc yrr| rsrrrcrrrrrrrs rmrzFastMCP.prompts rvc yrr|rs rmrzFastMCP.promptsrvc 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)rrrrs rmrzFastMCP.promptscn##** #)+  04/M/M+  rvc ddl}ddlm}||ur td|)|jdt d||}n td|B|jd t d|r'dd lm}t||stj|}|jrI|js=tjd |jd |jd |jd||} |rG|jD cic]\} } | t!| } } } | j#t%| } |j'| |xsdycc} } 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!Cannot mount a server onto itselfz=The 'prefix' parameter is deprecated, use 'namespace' insteadr?r@z,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.r\zParent server z0 has mask_error_details=True but mounted server z does not. Error details from z^ may leak through to clients. Set mask_error_details=True on the child server to prevent this.)rr&r')rC)fastmcp.server.providers.fastmcp_providerrrrr$fastmcp.server.providers.proxyr]rras_proxyrrrrrdrKwrap_transformrCr) rsrr(r tool_namesprefixrCrr]r*old_namenew_namers rmmountz FastMCP.mountLsk` M T>@A A   HMMO)   "  !OPP   HMMK*  G!&,7$--f5F  # #F,F,F NN  .""(++0N;;/"OP -V4 +5*:*:*<*<&Hh-8<<*<  ..}Z/HIH (io2>s;Ec 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() insteadr?r@rtcltj|}|r|j\}}||d|S|S)uGAdd prefix to resource URI: protocol://path → protocol://prefix/path./) URI_PATTERNmatchgroups)rtrrprotocolpaths rmadd_resource_prefixz2FastMCP.import_server..add_resource_prefixs>%%c*E!&$"F81TF33Jrvr_)update uri_template)rzeWhen importing from a server with a lifespan, the lifespan from the imported server will not be used.)rRcategoryrA[z] Imported server z with prefix '')rtrwrrwrwrw)rCrr$r2 model_copyrrr3rwrtrr4r rr5rrrRuntimeWarningrr) rsrrrCr rrnnew_urir|new_uri_templaterrs rm import_serverzFastMCP.import_serversP  > %  !++---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. rOpenAPIProvider) openapi_specrO route_maps route_map_fnmcp_component_fn mcp_namesrvalidate_outputrrr|)providers.openapir) clsrrOrrrrrrrrrr*s rm from_openapizFastMCP.from_openapi sCJ 7,%!%-+  ? ?h??rvc 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)rrOrrrrrrr|)r r setdefaultr AsyncClient ASGITransportropenapi)r!rrrrrrhttpx_client_kwargsrrrrO server_namer*s rm from_fastapizFastMCP.from_fastapiL s> 7  &"$ &&z3CD"" ))c2 !  'cii ,!%- F zFXFFrvc 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`r?r@)rbrrBrCrr$ create_proxy)r!backendrs rmrzFastMCP.as_proxy s=6    0 0 MMT)  G0x00rvc|j}||dtjdS|d|dtjdS)N-r?)rysecrets token_hex)r!r class_names rmrzFastMCP.generate_name sP\\ < \7#4#4Q#7"89 9 \4&'*;*;A*>)?@ @rv)NN).r str | Nonerr5rczstr | int | float | Nonerr5rlist[mcp.types.Icon] | NonerzAuthProvider | NonerzSequence[Middleware] | NonerzSequence[Provider] | NonerzSequence[Transform] | Nonerz"LifespanCallable | Lifespan | Nonerz*Sequence[Tool | Callable[..., Any]] | NonerzDuplicateBehavior | Noner bool | Nonerrxrr7rz int | Nonerr7rzAsyncKeyValue | NonerzSamplingHandler | Nonerz$Literal['always', 'fallback'] | Nonerzmcp.types.LoggingLevel | Nonerz dict[str, dict[str, Any]] | Nonerr )rwrw)rwr5)rlr5rwNone)rwzlist[mcp.types.Icon])rwr=)rrrrrwr )rr8rwr8)r*r>r(rwrwr8)r list[Tool]rwr9)rwzSequence[FastMCPComponent])r;rDrwr8)rDrwrErKrwr8)rHrwrwr8)rKrxrwzSequence[Tool]r)rrwrcVersionSpec | Nonerwz Tool | None)rKrxrwzSequence[Resource])rtrwrcr:rwzResource | None)rKrxrwzSequence[ResourceTemplate])rtrwrcr:rwzResourceTemplate | None)rKrxrwzSequence[Prompt])rrwrcr:rwz Prompt | None) rrwrdict[str, Any] | Nonercr:rKrxrr8rwrI) rrwrr;rcr:rKrxrrArwmcp.types.CreateTaskResult) rrwrr;rcr:rKrxrTaskMeta | Nonerwz'ToolResult | mcp.types.CreateTaskResult) rtrwrcr:rKrxrr8rwr/) rtrwrcr:rKrxrrArwr<) rtrwrcr:rKrxrr=rwz+ResourceResult | mcp.types.CreateTaskResult) rrwrr;rcr:rKrxrr8rwr,) rrwrr;rcr:rKrxrr=rwz)PromptResult | mcp.types.CreateTaskResult)rzTool | Callable[..., Any]rwrH)rrwrcr5rwr8)"rr}rr5rcstr | int | Nonerr5rr5rr6rset[str] | Nonerdict[str, Any] | NotSetT | Noner'ToolAnnotations | dict[str, Any] | Nonerlist[str] | Nonerr;r(AppConfig | dict[str, Any] | bool | Nonerbool | TaskConfig | Noner float | Noner"AuthCheck | list[AuthCheck] | Nonerrxrwr})"rr5rr5rcr>rr5rr5rr6rr?rr@rrArrBrr;rrCrrDrrErrFrrxrwCallable[[F], F])"rstr | AnyFunction | Nonerr5rcr>rr5rr5rr6rr?rr@rrArrBrr;rrCrrDrrErrFrrxrwztCallable[[AnyFunction], FunctionTool] | FunctionTool | partial[Callable[[AnyFunction], FunctionTool] | FunctionTool])rnzResource | Callable[..., Any]rwzResource | ResourceTemplate)r|r0rwr0)rtrwrr5rcr>rr5rr5rr6rr5rr?rz#Annotations | dict[str, Any] | Nonerr;rrCrrDrrFrwrG)rzPrompt | Callable[..., Any]rwr+)rr}rr5rcr>rr5rr5rr6rr?rr;rrDrrFrwr})rr5rr5rcr>rr5rr5rr6rr?rr;rrDrrFrwrG)rrHrr5rcr>rr5rr5rr6rr?rr;rrDrrFrwz|Callable[[AnyFunction], FunctionPrompt] | FunctionPrompt | partial[Callable[[AnyFunction], FunctionPrompt] | FunctionPrompt])NNNN) rrr(r5rr7rdict[str, str] | Nonerr5rwr8)rrrr5rwr8)NzOpenAPI ServerNNNNNT)rdict[str, Any]rOzhttpx.AsyncClient | Nonerrwrlist[RouteMap] | NonerOpenAPIRouteMapFn | NonerOpenAPIComponentFn | NonerrIrr?rrxrr rwr)NNNNNNN)rr rr5rrKrrLrrMrrIr*r;rr?rr rwr)r/}Client[ClientTransportT] | ClientTransport | FastMCP[Any] | FastMCP1Server | AnyUrl | Path | MCPConfig | dict[str, Any] | strrr rwr])rr5rwrw)6ryrzr{rrpropertyrrsetterrcrrrr#r%rr/r1rrFrIr2rdrhr3rsrvr4rrr5rrrrrrrrrPrrrrnrrrr classmethodr"r,rr __classcell__)rs@rmrr:s #'N -1"&-1$(26/3157;<@15*.$(/3%)!4837JN:>FJ1N N !N * N  N +N "N 0N -N /N 5N :N /N (N "!N ""-#N $#%N &'N (2)N *1+N ,$H-N .8/N 0$D1N 23N `7%%--..((,,00  $ $$'$&$ $(+DF<  0 :+(GG.AG G" :>/"d8<"4 @8<4545"445 45n)-4"!%4" 4"n7;!3 @7;0505!305 05f)-1"!%1" #1"h7;!3 @7;4545!345 45l<@'"T8<"4 @8<0505"405 05d,0 '+#) $    ,0) '+# )))) $ )  )) $)),0^P '+#%)^P^P)^P $ ^P  ^P#^P 1^P@ '+#  $       '+# ) )$ )  )  ) $))'+#%) ^W ^W$ ^W  ^W # ^W 5^W@,0 '+#) $    ,0) '+# )))) $ )  )) $)),0VV '+#%)VVVV)VV $ VV  VV#VV 3VVp 3:  $( "&-1 $9??C)-&*8<)- $37"%  "    +7='$6' !"1#$%& '*"& $( "&-1 $9??C)-&*8<)- $37"%  "    +7='$6' !"1#$%& '.04c $( "&-1 $9??C)-&*8<)- $37"%c,c c " c  c c+cc7c=c'c$c6c'c !c"1#c$%c( H)cJ ;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! h?(h?h? h? * h?  h? h?Z"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"1HAArvrc 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)r]_create_client_factoryclient_factoryr|)rr]rT)targetrr]rTrUs rmr.r. s1V ,F3N  %   rv)rcr:rwz#mcp.types.RequestParams.Meta | None)rrJrwr8)rwztuple[bool, Any])rrHrwrx)rrrwzAsyncIterator[Any])rrrwzYCallable[[LowLevelServer[LifespanResultT]], AbstractAsyncContextManager[LifespanResultT]])rVrNrr rwr])r __future__rrloggingrer2rCcollections.abcrrr contextlibrr dataclassesr functoolsr pathlibr typingr r rrrrrr mcp.typesrekey_value.aio.adapters.pydanticrkey_value.aio.protocolsrkey_value.aio.stores.memoryrmcp.server.lowlevel.serverrmcp.shared.exceptionsrrrrrpydanticrrrstarlette.routingrtyping_extensionsrrbfastmcp.serverfastmcp.apps.configr r!r"fastmcp.exceptionsr#r$r%r&r'r(r)fastmcp.mcp_configr*fastmcp.promptsr+fastmcp.prompts.baser,fastmcp.prompts.function_promptr-fastmcp.resources.baser.r/fastmcp.resources.templater0fastmcp.server.authr1r2r3r4fastmcp.server.lifespanr5fastmcp.server.low_levelr6fastmcp.server.middlewarer7r8r9fastmcp.server.mixinsr:r;r<fastmcp.server.providersr=r>"fastmcp.server.providers.aggregater?fastmcp.server.tasks.configr@rAfastmcp.server.telemetryrBfastmcp.server.transformsrCrD$fastmcp.server.transforms.visibilityrErFfastmcp.settingsrGDuplicateBehaviorSettingfastmcp.tools.baserHrIfastmcp.tools.function_toolrJfastmcp.tools.tool_transformrKfastmcp.utilities.componentsrLrMfastmcp.utilities.loggingrNfastmcp.utilities.typesrOrPrQfastmcp.utilities.versionsrRrSfastmcp.clientrTfastmcp.client.clientrUfastmcp.client.samplingrVfastmcp.client.transportsrWrX fastmcp.server.providers.openapirYOpenAPIComponentFnrZr[OpenAPIRouteMapFnrr]ryrrnFilterrp getLogger addFilterr}rrr Transportcompilerrrrrrrrrr.r|rvrmrs-;"   PPP ;136* ?'"   )"-:;7UU,3MMSS<@<0VJ/4<J0EE %47KR9P; H  (<F7>>F ./99 " CxS)*@A# E# E#]#/ # u # p #s# !#T#8#<#:#A#Y#O# g!#(   = > bjj-.  "=o"NN '& ;F2    ,0! u!A O u!AzC4 444rv