$jzu UdZddlmZddlZddlZddlZddlZddlZddlm Z m Z m Z m Z ddl mZmZddlmZddlmZddlmZdd lmZmZmZmZmZmZmZddlZddlZ dd 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/m0Z0ddl/m1Z2ddl3m4Z4ddl5m6Z6ddl7Z7ddl8Z7ddl9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDm1Z1ddlEmFZFddlGmHZHddlImJZJddlKmLZLddlMmNZNmOZOddlPmQZQddlRmSZSmTZTmUZUmVZVddlWmXZXddlYmZZZddl[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/lmZdd0lmZdd1lmZdd2lmZmZdd3lmZdd4lmZdd5lmZdd6lmZeeZGd7d8ejZejd9eed:e d;ef<Zed=Zsid>d?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdQdSdQdTdUdVdWdXdYdZd[Zd\ed]<d}dbZedcZejddZe degee(fZd~dgZddkZddlZeddoZddrZGdsdteZGdudvefe_e`eaee(Zdd|ZdS)z5FastMCP - 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) 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) MiddlewareMiddlewareContext) LifespanMixinMCPOperationsMixinTransportMixin) LocalProviderProvider)AggregateProvider) TaskConfigTaskMeta) server_span) ToolTransform Transform)apply_session_transforms is_enabled)DuplicateBehavior)Tool ToolResult) FunctionToolToolTransformConfig)FastMCPComponent_coerce_version) get_logger)FastMCPBaseModelNotSetNotSetT) VersionSpecversion_sort_key)Client)FastMCP1Server)SamplingHandler)ClientTransportClientTransportT) ComponentFn)RouteMap) RouteMapFn FastMCPProxyceZdZddZdS)_SuppressUnlistedToolWarningrecordlogging.LogRecordreturnboolc.d|vS)Nznot listed, no validation) getMessage)selfras ]/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/fastmcp/server/server.pyfilterz#_SuppressUnlistedToolWarning.filterms*&2C2C2E2EEEN)rarbrcrd)__name__ __module__ __qualname__rirjrhr`r`ls.FFFFFFrjr`zmcp.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_KWARGSkwargsdict[str, Any]rcNonec|D]+}|tvr td|dt|,|r/tddd|DdS)z2Raise helpful TypeErrors for kwargs removed in v3.zFastMCP() no longer accepts `z`. z.FastMCP() got unexpected keyword argument(s): z, c34K|]}t|VdSN)repr).0ks rh z(_check_removed_kwargs..s)F_F_STtAwwF_F_F_F_F_F_rjN)r TypeErrorjoin)rkeys rh_check_removed_kwargsrs / ! !NNN8LNN  "  aTYYF_F_X^F_F_F_=_=_ a a     rj)stdiohttpssezstreamable-httpz^([^:]+://)(.*?)$FastMCP[LifespanResultT]tuple[bool, Any]cjddlm}|dk}|rdSddlm}d|fS)a@Get auth context for the current request. Returns a tuple of (skip_auth, token) where: - skip_auth=True means auth checks should be skipped (STDIO transport) - token is the access token for HTTP transports (may be None if unauthenticated) Uses late import to avoid circular import with context.py. r)_current_transportr)TN)get_access_tokenF)fastmcp.server.contextrgetfastmcp.server.dependenciesr)ris_stdiors rh_get_auth_contextrs`:99999!%%''72H|<<<<<< ##%% &&rjtoolrHrdc|j}|sdS|d}t|tsdS|d}t|tsdSd|vS)u'Check whether a tool should be visible to the model. Tools registered via ``@app.tool()`` (without ``model=True``) have ``meta["ui"]["visibility"] == ["app"]`` — they are callable by app UIs but should not appear in the model's tool list. Returns True (visible) when: - The tool has no ``meta.ui.visibility`` (normal tools). - ``"model"`` is in the visibility list (e.g. ``["model"]`` or ``["app", "model"]``). Returns False when the visibility list exists and does not contain ``"model"`` (e.g. ``["app"]``). Tui visibilitymodelmetar isinstancedictlistrrrrs rh_is_model_visiblersq 9D t $B b$  t %%J j$ ' 't j  rjc|j}|sdS|d}t|tsdS|d}t|tsdSd|vS)ulCheck whether a tool has explicitly opted into app-callable visibility. Gates the dispatcher's hashed-name routing path: only tools whose ``meta.ui.visibility`` list contains ``"app"`` can be reached via ``_`` 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. Frrapprrs rh_is_app_visiblersq 9D u $B b$  u %%J j$ ' 'u J rjserverAsyncIterator[Any]cKiWVdS)zDefault lifespan context manager that does nothing. Args: server: The server instance this lifespan is managing Returns: An empty dictionary as the lifespan result. Nrn)rs rhdefault_lifespanrs HHHHHHrjfastmcp_serverYCallable[[LowLevelServer[LifespanResultT]], AbstractAsyncContextManager[LifespanResultT]]c.tdfd }|S)Nlow_level_serverLowLevelServer[LifespanResultT]rcAsyncIterator[LifespanResultT]cvKjturiWVdSjstdjWVdS)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)rrs rhwrapz_lifespan_proxy..wrapse  #'7 7 7HHHH F2 \  -------rj)rrrcr)r )rrs` rh_lifespan_proxyrs5  . . . . . . KrjceZdZUdZded<dS) StateValuez(Wrapper for stored context state values.rvalueN)rkrlrm__doc____annotations__rnrjrhrrs22JJJJJrjrc`eZdZ ddddddddddddddddddddddوfd,Zdd/Zedd0Zedd1Zejdd4Zedd5Z edd6Z edd8Z edd:Z dd?Z ddAZdBdCdfdGZddIZdfdK ZddNZddRZddTZddUdfdXZ ddfd[ Z ddfd\ ZddUdfd^Z ddfda Z ddfdb ZddUdfddZ ddfdf Z ddfdg ZddUdfdiZ ddfdk Z ddfdl Z e! dddddmddrZ"e! ddddsddvZ" dddddmddyZ"e!ddddmdd{Z#e!dddsdd|Z#ddddmdd~Z#e! dddddmddZ$e! ddddsddZ$ dddddmddZ$ddZ%dddZ&e!dddddde'ddddddddddZ(e! ddddddde'ddddddddddZ( ddddddde'ddddddddddZ(ddZ)ddZ*ddddddddddddd ddZ+ddZ,e!dddddddddd ddZ-e! ddddddddddd ddZ- ddddddddddd ddZ- dddZ. dddZ/e0 dddЄZ1e0 d d d҄Z2e0d dքZ3e0dd dׄZ4xZ5S( FastMCPNT)version website_urliconsauth middleware providers transformslifespantools on_duplicatemask_error_detailsdereference_schemasstrict_input_validationlist_page_sizetaskssession_state_storesampling_handlersampling_handler_behaviorclient_log_levelname str | None instructionsrstr | int | float | Nonerrlist[mcp.types.Icon] | NonerAuthProvider | NonerSequence[Middleware] | NonerSequence[Provider] | NonerSequence[Transform] | Noner"LifespanCallable | Lifespan | Noner*Sequence[Tool | Callable[..., Any]] | NonerDuplicateBehavior | Noner bool | Nonerrdrr int | NonerrAsyncKeyValue | NonerSamplingHandler | Noner$Literal['always', 'fallback'] | Nonermcp.types.LoggingLevel | Nonerrc :t|t| pd|_||nd|_d|_d|_g|_|p t|_ tt|j td|_ t|j|_||j|pgD]}||| pgD]}||| | nt"jj|_||dkrt+d||_| &t/t0t2| |_n*t/t0t2t6|_d|_d|_d|_t?j |_!t?j"|_#tIt2||p|%tM|p t"j'|||tQ| |_)||_*| rC| D]@}tW|tXstYj-|}|.|A||nt"jj/|_/||nt"jj0|_0tc|pg|_2|r(dd l3m4}|j25||6||_7|pd |_8dS) NrqF fastmcp_state) key_valuepydantic_modeldefault_collection)rrz)list_page_size must be a positive integer)r)fastmcprrrrrr)DereferenceRefsMiddlewarefallback)9rsuper__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_sizerLifespanCallablerrrrr_lifespan_ref_countasyncioLock_lifespan_lockEvent_startedr7 generate_namerN __version__r _mcp_serverrrrH from_functionadd_toolrrrr%fastmcp.server.middleware.dereferencerappend_setup_handlersrr)rgrrrrrrrrrrrrrrrrrrrrrrptrr __class__s rhrzFastMCP.__init__s~4 f%%% 7C7Mv9>8Iuuu&  8:$.A-QKMM9H9T)%.: : : /<+/ / /  $.///b ! !A   a !r " "A   q ! ! ! ! "-  !4    %.A*=*=HII I+9  @D 18AADNN""2?"CEUVVDN8<*/!() ,3LNN'.} BP B -++--#G,,C0C%#$D999 B B B *.  $ $ $!$--4-d33D d####'2 $ #!9 $ +  !2  -11Ar,B,B  @       O " "#<#<#>#> ? ? ? 8H % 3 &&&rjrcstrc@t|jd|jdS)N())typerkrrgs rh__repr__zFastMCP.__repr__s$t**%66 6666rjc|jjSr)r rrs rhrz FastMCP.names$$rjc|jjSrr rrs rhrzFastMCP.instructionss,,rjrrc||j_dSrr)rgrs rhrzFastMCP.instructionss(-%%%rjc|jjSr)r rrs rhrzFastMCP.versions''rjc|jjSr)r rrs rhrzFastMCP.website_urls++rjlist[mcp.types.Icon]cP|jjgSt|jjSr)r rrrs rhrz FastMCP.iconss'   ! )I(.// /rjr=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 rhlocal_providerzFastMCP.local_providers ##rjcontextMiddlewareContext[Any] call_next2Callable[[MiddlewareContext[Any]], Awaitable[Any]]c|K|}t|jD]}t||}||d{VS)z)Builds and executes the middleware chain.)r)N)reversedrr )rgr'r)chainmws rh_run_middlewarezFastMCP._run_middlewaresZ 4?++ 1 1BB%000EEU7^^#######rjr8c:|j|dSr)rr)rgrs rhadd_middlewarezFastMCP.add_middlewares z*****rj namespaceproviderr>r4cNt||dS)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" r3N)rr)rgr5r4rs rhrzFastMCP.add_providers( X;;;;;rj list[Tool]c4ddlmmfd|DS)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_wirec@g|]}|r |n|Srnrn)rrr9r:s rh z0FastMCP._rewrite_prefab_uris..sF   KL__Q-?-? F & &q ) ) )Q   rj))fastmcp.server.providers.prefab_synthesisr9r:)rgrr9r:s @@rh_rewrite_prefab_uriszFastMCP._rewrite_prefab_uriss\             PU    rjSequence[FastMCPComponent]cKttd{V}d|D}d|D}d|D}d|D}|jD]n}||d{V}||d{V}||d{V}||d{V}og||||S)zGet task-eligible components with all transforms applied. Overrides AggregateProvider.get_tasks() to apply server-level transforms after aggregation. AggregateProvider handles provider-level namespacing. Nc<g|]}t|t|Srn)rrHrcs rhr<z%FastMCP.get_tasks..s'>>>q*Q*=*=>>>>rjc<g|]}t|t|Srn)rr/rBs rhr<z%FastMCP.get_tasks..s'FFF1jH.E.EFQFFFrjc<g|]}t|t|Srn)rr1rBs rhr<z%FastMCP.get_tasks..s(NNN1j.s'BBBJq&,A,AB1BBBrj)rr get_tasksr list_toolslist_resourceslist_resource_templates list_prompts)rg componentsr resources templatesprompts transformrs rhrGzFastMCP.get_tasks s] 1 1 3 333333344 ?>J>>>FF FFF NN NNN BBjBBB < z$FastMCP.list_tools..lsdooUo.S.Srjr'r)cNg|]"}t|t| |#SrnrFrrrs rhr<z&FastMCP.list_tools..ss1PPP1AP;LQ;O;OPQPPPrjtoken component)rrr'Contextr9mcptypesListToolsRequestr/rrrHrEr>rrr3r5r$r) rgr`ctx mw_contextr skip_authrt authorizedrrs ` rhrHzFastMCP.list_toolsZs>)11$1??& & & & & & & 3 .I66l6KK#"'$'  "11&SSSS2& & & & & & & & & & & & & &  uww113333333344E2599999999EPPPPPE--e44E022 Iu%'J ( ( !TY%:%ETBBBC!%4TY%D%DDDDDDD%$%-!!! !!!$''''M& & & & & & & & & & & & & & & & & & & & & & & & & & & & & & s=AF BF 2E F  EF EF  FFVersionSpec | None Tool | NonecKt||d{V}|dSt\}}|sH|jAt ||} t |j|d{VsdSn#t $rYdSwxYw|S)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. Nrs)r _get_toolrrr3r5r$)rgrrrr|rtrzrs rhrzFastMCP._get_toolsWW&&tW55555555 <4-.. 5 TY2ET:::C ,TY<<<<<<<< 4 %   tt  A:: BBcKt|d{V}|dSt|gd{V}|r2t|drt |dr|dS|dSfdtd{VD}t t|d{V}d|D}t\}}g} |D]_} |sF| j?t|| } t| j| d{Vs9n#t$rYFwxYw| | `| sdSttt| t S)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. Nrc*g|]}|jk |Srnr)rrrs rhr<z$FastMCP.get_tool..s MMM1afnnQnnnrjcNg|]"}t|t| |#Srnrqrrs rhr<z$FastMCP.get_tool..s1RRR:a==R=Nq=Q=QR1RRRrjrsr)rget_toolrErFrrHrrrr3r5r$rrrHmaxrT) rgrrrr all_toolsenabledr|rtr}rrzrs ` rhrzFastMCP.get_tools&WW%%dG44444444 <4/v66666666  Za)) .?a.I.I 8O  4MMMMegg&8&8&:&: : : : : : :MMM 7 BBBBBBBBCC RRiRRR,.. 5!#  ! !A !3!;;;!0!=!=======! !)H   a  4D#j.>???@@@sD.. D;:D;Sequence[Resource]c&Ktjj4d{V}|rFt iddd|}|fdd{Vcdddd{VSt td{V}t|d{V}d |D}d d l m }| |d{Vt\}}g}|D]_} |sF| j?t|| } t!| j|d{Vs9n#t"$rYFwxYw|| `|cdddd{VS#1d{VswxYwYdS) 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. rcNrerfzresources/listrgc0dSrl)rIrms rhrnz(FastMCP.list_resources..sd.A.AQV.A.W.Wrjroc0g|]}t||SrnrFrrs rhr<z*FastMCP.list_resources..#???qA????rjr)synthesize_prefab_resourcesrs)rrr'rvr9r/rrrIrEr=rextendrrr3r5r$r) rgr`rzr{rMrr|rtr}resourcers ` rhrIzFastMCP.list_resourcess>)11$1??' ' ' ' ' ' ' 3 .#"+$'  "11&WWWW2' ' ' ' ' ' ' ' ' ' ' ' ' ' 577#9#9#;#;;;;;;;<#>t#D#DDDDDDD E E E022 Iu)+J% , , !X]%>%EXFFFC!%4X]C%H%HHHHHHH%$%-!!! !!!(++++O' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' s<6F9B/F)EF EFEF F  F uriResource | NonecKt||d{V}|dSt\}}|sH|jAt ||} t |j|d{VsdSn#t $rYdSwxYw|S)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. Nrs)r _get_resourcerrr3r5r$)rgrrrr|rtrzrs rhrzFastMCP._get_resources..sG<<<<<<<<  4-.. 5 X]6EX>>>C ,X]C@@@@@@@@ 4 %   tt rcKt|d{V}|dSt|gd{V}|rt|dr|dS|dSfdtd{VD}t t|d{V}d|D}t \}}g} |D]_} |sF| j?t|| } t| j| d{Vs9n#t$rYFwxYw| | `| sdSttt| tS)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. NrcDg|]}t|jk|Srn)rr)rrrs rhr<z(FastMCP.get_resource..Ms,XXXqc!%jjTWFWFWFWFWFWrjc0g|]}t||Srnrrs rhr<z(FastMCP.get_resource..O#===z!}}=1===rjrsr)r get_resourcerErFrIrrrr3r5r$rrr/rrT) rgrrrrM all_resourcesrr|rtr}rrzrs ` rhrzFastMCP.get_resource/s$--c7;;;;;;;;  43H:>>>>>>>>  IaL11 Q<   4XXXX%''*@*@*B*B$B$B$B$B$B$BXXX #;M#J#JJJJJJJKK ==m===,.. 5%'  ! !A !3!;;;!0!=!=======! !)H   a  4Hc*2BCCCDDD<D D&%D&Sequence[ResourceTemplate]cKtjj4d{V}|rFt iddd|}|fdd{Vcdddd{VSt td{V}t|d{V}d |D}t\}}g}|D]_}|sF|j ?t|| } t|j |d{Vs9n#t$rYFwxYw||`|cdddd{VS#1d{VswxYwYdS) 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. rcNrerfzresources/templates/listrgc0dSrl)rJrms rhrnz1FastMCP.list_resource_templates..us d.J.J',/K//rjroc0g|]}t||Srnrrrs rhr<z3FastMCP.list_resource_templates..}rrjrs)rrr'rvr9r/rrrJrErrr3r5r$r) rgr`rzr{rNr|rtr}templaters ` rhrJzFastMCP.list_resource_templatesas>)11$1??       3 .#"5$'  "11&2              "577#B#B#D#DDDDDDDEEI6yAAAAAAAAI??I???I022 Iu13J% , , !X]%>%EXFFFC!%4X]C%H%HHHHHHH%$%-!!! !!!(++++A                              <6E9BE?DE D)&E(D))E E #E ResourceTemplate | NonecKt||d{V}|dSt\}}|sH|jAt ||} t |j|d{VsdSn#t $rYdSwxYw|S)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. Nrs)r_get_resource_templaterrr3r5r$)rgrrrr|rtrzrs rhrzFastMCP._get_resource_templates77WEEEEEEEE  4-.. 5 X]6EX>>>C ,X]C@@@@@@@@ 4 %   tt rcKt|d{V}|dSt|gd{V}|rt|dr|dS|dSfdtd{VD}t t|d{V}d|D}t \}}g} |D]_} |sF| j?t|| } t| j| d{Vs9n#t$rYFwxYw| | `| sdSttt| tS)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. Nrc>g|]}||Sr)matches)rrrs rhr<z1FastMCP.get_resource_template..s3   yy~~) )))rjc0g|]}t||Srnrrrs rhr<z1FastMCP.get_resource_template..rrjrsr)rget_resource_templaterErFrJrrrr3r5r$rrr1rrT) rgrrrrN all_templatesrr|rtr}rrzrs ` rhrzFastMCP.get_resource_templates$66sGDDDDDDDD  43H:>>>>>>>>  IaL11 Q<   4     77::<<<<<<<<   #;M#J#JJJJJJJKK ==m===,.. 5-/  ! !A !3!;;;!0!=!=======! !)H   a  4$c*:J&K&K&KLLLrSequence[Prompt]cKtjj4d{V}|rFt iddd|}|fdd{Vcdddd{VSt td{V}t|d{V}d |D}t\}}g}|D]_}|sF|j ?t|| } t|j |d{Vs9n#t$rYFwxYw||`|cdddd{VS#1d{VswxYwYdS) 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. rcNrerfz prompts/listrgc0dSrl)rKrms rhrnz&FastMCP.list_prompts..sd.?.?u.?.U.Urjroc0g|]}t||Srnrrrs rhr<z(FastMCP.list_prompts..s#;;;QZ]];q;;;rjrs)rrr'rvr9r/rrrKrErrr3r5r$r) rgr`rzr{rOr|rtr}promptrs ` rhrKzFastMCP.list_promptss>)11$1??       3 .#")$'  "11&UUUU2              !5!5!7!777777788G4W========G;;';;;G022 Iu')J! * * !V[%<%EVDDDC!%4V[#%F%FFFFFFF%$%-!!! !!!&))))=                              r Prompt | NonecKt||d{V}|dSt\}}|sH|jAt ||} t |j|d{VsdSn#t $rYdSwxYw|S)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. Nrs)r _get_promptrrr3r5r$)rgrrrr|rtrzrs rhrzFastMCP._get_promptsww**499999999 >4-.. 5 V[4EV<<>>>>>>> 4 %   tt  rcKt|d{V}|dSt|gd{V}|rt|dr|dS|dSfdtd{VD}t t|d{V}d|D}t \}}g} |D]_} |sF| j?t|| } t| j| d{Vs9n#t$rYFwxYw| | `| sdSttt| tS)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. Nrc*g|]}|jk |Srnr)rrrs rhr<z&FastMCP.get_prompt..Es QQQQ!&D..q...rjc0g|]}t||Srnrrs rhr<z&FastMCP.get_prompt..Gs#;;;Z]];1;;;rjrsr)r get_promptrErFrKrrrr3r5r$rrr,rrT) rgrrrrO all_promptsrr|rtr}rrzrs ` rhrzFastMCP.get_prompt's$ww))$88888888 >41&::::::::  z'!*-- 1:   4QQQQ(<(<(>(>">">">">">">QQQ !9+!F!FFFFFFFGG ;;k;;;,.. 5#%  ! !A !3!;;;!0!=!=======! !)H   a  4FC 0@AAABBBrrr` task_meta argumentsdict[str, Any] | NonerrIc KdSrrnrgrrrr`rs rh call_toolzFastMCP.call_toolYs Srj)rr`rAmcp.types.CreateTaskResultc KdSrrnrs rhrzFastMCP.call_toold &)SrjTaskMeta | None'ToolResult | mcp.types.CreateTaskResultc Kddlm}tjj4d{V}|rtt ttj ||piddd| } |fd  d{Vcdddd{VStd |dj d |5} |d{V} | ||} | | \} } | | d{V} | {t\}}|sh| ja t#|| }t%| j|d{Vst'd|n!#t($rt'd|dwxYw| t'd|| | jt1| j | |pid{V cdddcdddd{VS#t6$rt8d|t<t>f$rt8d|t@$r}t8d|tC|tDj#r |j$j%dkrtMd|tC|tDj'rtMd|j(rtMd||tMd|d||d}~wwxYw#1swxYwY dddd{VdS#1d{VswxYwYdS)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_namercNrrrerfz tools/callrgcd|jj|jjpidSNFr)rrhrrr'rgrrs rhrnz#FastMCP.call_tool..s8dnn,17R '',"+ /=//rjroz tools/call rrrszUnknown tool: fn_keyrzError calling tool zError validating tool 0Rate limited by upstream API, please retry later(Upstream request timed out, please retry: ))#fastmcp.server.providers.addressingrrrr'rvr9rrwrxr/rBrrget_tool_by_hashrrr3r5r'r$set_attributesget_span_attributesrr r_runr&logger exceptionrPydanticValidationError ExceptionrhttpxHTTPStatusErrorresponse status_coder*TimeoutExceptionr)rgrrrr`rrrzr{spanrhasheddigest local_namer|rtauth_ctxes` ` ` rhrzFastMCP.call_toolossH      >)11$1??P PP PP PP PP PP PP P3 ./DEI;;!Y_"<$"'$' "11&2        P PP PP PP PP PP PP PP PP PP PP PP PP PP P.$d$$lDIvt9 P*.--g-*N*N$N$N$N$N$N$N <66t<$>???(Y-=-E ' $( C C CIP!%9?i!P!PPPPPPPPE9 P9 P9 P9 P9 P9 P9 P/P PP PP PP PP PP PP PP PP PP PP PP PP PP Pt$$$%C4%C%CDDD')@A$$%Fd%F%FGGG PPP$$%C4%C%CDDD"!U%:;;%:1S88"+ R###$%"!U%;<<!'F !/O'(Fd(F(FGGQN#$G$$G$GA$G$GHHaO!PS9 P9 P9 P9 P9 P9 P9 P9 P9 P/P PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PP PsvA$M$.M$ A*M4>E32M3FAM/H- M$-AM B1L==MMM M$ M M$$ M.1M.r0c KdSrrnrgrrr`rs rh read_resourcezFastMCP.read_resources rjc KdSrrnrs rhrzFastMCP.read_resources &)Srj+ResourceResult | mcp.types.CreateTaskResultc  Ktjj4d{V}|rut |}t t j|ddd|} |fd d{Vcdddd{VStd |dj d || 5}d dl m } | |d{V} | a|| | d{Vcdddcdddd{VS|d{V} | s|| jt'| j | d{V cdddcdddd{VS#t*t,f$rt.d|t2$r} t.d|t5| t6jr | jjdkrt?d| t5| t6j rt?d| j!rt?d|| t?d|d| | d} ~ wwxYw"|d{V} | )tGd|tGd|d|| | $|}|Jjt'| j | ||d{V cdddcdddd{VS#t*t,f$rt.d|t2$r} t.d|t5| t6jr | jjdkrt?d| t5| t6j rt?d| j!rt?d|| t?d|d| | d} ~ wwxYw#1swxYwY dddd{VdS#1d{VswxYwYdS)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 rcN)rrerfzresources/readrgcdt|jjdSr)rrrhrrs rhrnz'FastMCP.read_resource..6s6d.@.@GO/00 '',"+ /A//rjrozresources/read r) resource_urir)!synthesize_prefab_resource_by_urirrrzError reading resource rrrrzUnknown resource: version )%rrr'rvrr9rwrxReadResourceRequestParamsr/rBrr=rrr_readrrr rr&rrrrrrrrrr)rrrr'r)rgrrr`rrz uri_paramr{rr synthesizedrrrparamss` ` ` rhrzFastMCP.read_resources J>)11$1??j Wj Wj Wj Wj Wj Wj W3 "3KK .I??I?NN#"+$'  "11&2j Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj W*'#''   U W%F$EdC$P$PPPPPPP *'' (G(G(I(IJJJ!,!2!2Y!2!G!GGGGGGG%U WU WU WU WU WU WU W+j Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj WT"&!2!23!2!H!HHHHHHH'''(D(D(F(FGGG ,1A1I$+Ihl$K$K$K !%-^^i^%H%HHHHHHHH7U WU WU WU WU WU WU W+j Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wb)(3(()J3)J)JKKK$!!!(()J3)J)JKKK%a)>??) z5<<&3$V'"'"'(!)&a)?@@%"/ J###$% 3%"/ A# A A###$%,BcBBqBB !#!,"&!;!;C!;!Q!QQQQQQQ#+,H,H,HIII'HSHHWHH##H$@$@$B$BCCC!))#..)))(Y-=-E ' (, G G GIW!)Vy!Q!QQQQQQQQEU WU WU WU WU WU WU W+j Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wp%h/$$%Fs%F%FGGG WWW$$%Fs%F%FGGG!!U%:;;%:1S88"/ R###$%"!U%;<<!+F !/V+,Mc,M,MNNTUU'(N#(N(N1(N(NOOUVVWMU WU WU WU WU WU WU WU WU W+j Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj Wj WsA%S )S AR+# S A&R+)G$ S $8KB1K  KB*R+=N: S :8R(2B1R##R((R++R/ /S 2R/ 3S  SSr-c KdSrrnrs rh render_promptzFastMCP.render_prompts srjc KdSrrnrs rhrzFastMCP.render_promptrrj)PromptResult | mcp.types.CreateTaskResultc TKtjj4d{V}|rgt t j||ddd|}|fd d{Vcdddd{VStd |dj d |5} | d{V} | td || | jt!| j | |d{V cdddcdddd{VS#t&t(f$rt*d|t.$rR} t*d|jrt3d|| t3d|d| | d} ~ wwxYw#1swxYwY dddd{VdS#1d{VswxYwYdS)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 rcNrrerfz prompts/getrgc`|jj|jjdSr)rrhrrrs rhrnz'FastMCP.render_prompt..s6d.@.@,1 '',"+ /A//rjroz prompts/get rrzUnknown prompt: rrzError rendering prompt r)rrr'rvr9rwrxGetPromptRequestParamsr/rBrrr'rrrr r_renderr&rrrrrr() rgrrrr`rrzr{rrrs ` ` ` rhrzFastMCP.render_promptsW@>)11$1??* V* V* V* V* V* V* V3 .I<<!Y=$"($' "11&2        * V* V* V* V* V* V* V* V* V* V* V* V* V* V0%t%%}di4 V#tWEEEEEEEE>'(C4(C(CDDD##F$>$>$@$@AAA(Y-=-E ' &* E E EI V!' Y!O!OOOOOOOO V V V V V V V1* V* V* V* V* V* V* V* V* V* V* V* V* V* VF%h/$$%Gt%G%GHHH VVV$$%Gt%G%GHHH/U)*LD*L*LMMSTT%&M&M&M!&M&MNNTUU V V V V V V V V V V1* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* V* Vs\AHH6A8G8/E+ H+8G5#A G00G55G88G< <H?G< H H!$H!rTool | Callable[..., Any]rHc6|j|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)rgrs rhrzFastMCP.add_tools#,,T222rjctjjrtjdt d |j||dS#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.rVrWNzTool z not foundr) rrrYrZrqr%r remove_toolKeyErrorr')rgrrs rhrzFastMCP.remove_tools   0  M@)         , ,T7 ; ; ; ; ;   #$>D$>$>$>??TI>>>>>>  s A 8B)rrtitle descriptionrtags output_schemar exclude_argsrrtasktimeoutr name_or_fnrostr | int | Noner r r set[str] | Noner dict[str, Any] | NotSetT | Noner'ToolAnnotations | dict[str, Any] | Noner list[str] | Nonerr(AppConfig | dict[str, Any] | bool | Nonerbool | TaskConfig | Noner float | None"AuthCheck | list[AuthCheck] | NonecdSrrnrgrrrr r rr r rr rrrrrs rhrz FastMCP.tool#s & CrjCallable[[F], F]cdSrrnrs rhrz FastMCP.tool8s &3rjstr | AnyFunction | NonetCallable[[AnyFunction], FunctionTool] | FunctionTool | partial[Callable[[AnyFunction], FunctionTool] | FunctionTool]c| 3| dur/| rt| ni} | durd| d<nt| | d<|j||||||||| | | | | 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") ``` NFTr) rrr r rr r rr rrrr)rr"rrr)rgrrrr r rr r rr rrrrrresults rhrz FastMCP.toolMsP ?s%//!%-4:::2Dd{{!T 4S99T %** #'#%)t/M+  " rjrResource | Callable[..., Any]Resource | ResourceTemplatec6|j|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)rgrs rhr%zFastMCP.add_resources#00:::rjrr1c6|j|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)rgrs rhr'zFastMCP.add_templates#00:::rj) rrr r r mime_typer rrrrrr(#Annotations | dict[str, Any] | Nonec t|tstdt||}t| tr,| jt d| jt d| 3| dur/| rt| ni} | durd| d<nt| | d<|j ||||||||| | | | 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 @resourceNuresource_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) rrr r rr(r rrrr) rrrr#r!rrrrr"rrr)rgrrrr r rr(r rrrrrinner_decorators rhrzFastMCP.resources4J#s## < )i88  c9 % % + K ~) Y ?s%//!%-4:::2Dd{{!T 4S99T .77 ##)t/M8   rjrPrompt | Callable[..., Any]r,c6|j|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)rgrs rhr.zFastMCP.add_prompt?s#..v666rj rrr r rr rrrc dSrrn rgrrrr r rr rrrs rhrzFastMCP.promptJs  Crjc dSrrnr1s rhrzFastMCP.promptZs 3rj|Callable[[AnyFunction], FunctionPrompt] | FunctionPrompt | partial[Callable[[AnyFunction], FunctionPrompt] | FunctionPrompt]c \|j||||||||| | n|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") ``` Nr/)rrrr1s rhrzFastMCP.promptjsOn#** #)t/M+   rjrras_proxy tool_namesdict[str, str] | Noneprefixc \ddl}ddlm}|,|jdtd||}nt d|J|jdtd|r0dd lm}t||st |}|j r:|j s3t d |jd |jd |jd ||} |r@d|D} | t#| } || |pddS)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' insteadrVrWz,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.c6i|]\}}|t|S)rrK)rold_namenew_names rh z!FastMCP.mount..,s:&Hh-8<<<rjr2r3)rZ)fastmcp.server.providers.fastmcp_providerr:rqr%rfastmcp.server.providers.proxyr^rrr5rrwarningritemswrap_transformrCr) rgrr4r5r6r8rZr:r^r5rs rhmountz FastMCP.mounts` MMMMMM   HMO)      "  !OPPP   HMK*      6GGGGGG!&,776$--f55F  # F,F  NNPPP"(+PP;PPP   -_V44  J*4*:*:*<*<J ..}Z/H/HIIH (io2>>>>>rjc :Kddl}|jdtddd }|d{VD];}|r"|d |d |ji }||<|d{VD]O}|r6|t|j |}|d|i }| |P| d{VD]B}|r)||j |} |d| i }| |C|d{VD];} |r"| d |d | ji } || <|jt"krddlm} | dt$d|r0t&d|jd|jd|ddSt&d|jd|jdS)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() insteadrVrWrrr8rcc~t|}|r |\}}||d|S|S)uGAdd prefix to resource URI: protocol://path → protocol://prefix/path./) URI_PATTERNmatchgroups)rr8rIprotocolpaths rhadd_resource_prefixz2FastMCP.import_server..add_resource_prefixesL%%c**E 4!&$"3F33T333Jrjr_)update uri_template)rqzeWhen importing from a server with a lifespan, the lifespan from the imported server will not be used.)rhcategoryrX[z] Imported server z with prefix '')rrr8rrcr)rZrqr%rH model_copyrrrIrrr%rJrPr'rKr.rrRuntimeWarningrr{) rgrr8rZrMrrnew_urirnew_uri_templaterrqs rh import_serverzFastMCP.import_server5sP  > %        !++--------  D Qv&7N7N497N7N.OPP MM$    %3355555555 ( (H H--c(,.?.?HH#..ug6F.GG   h ' ' ' '$<<>>>>>>>> ( (H #6#6x7Lf#U#U #..*,<=/   h ' ' ' '#//11111111 $ $F W**6f;T;Tv{;T;T2U*VV OOF # # # #  / / / % % % % % % D'      I LLUDIUUUUFUUU      LLGTYGG&+GG H H H H HrjOpenAPI Server openapi_specrrehttpx.AsyncClient | None route_mapslist[RouteMap] | None route_map_fnOpenAPIRouteMapFn | Nonemcp_component_fnOpenAPIComponentFn | None mcp_namesvalidate_outputrr c Lddlm} | |||||||| } |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)rZrer\r^r`rbr rcrrrn)providers.openapirg) clsrZrerr\r^r`rbr rcrrgr5s rh from_openapizFastMCP.from_openapisfJ 766666,_%!%-+    s? ??h???rjhttpx_client_kwargsc ddlm} |i}|ddtjd dtj|i|} |p|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. rerfNbase_urlzhttp://fastapi transport)r)rZrer\r^r`rbr rhrn)rirg setdefaultr AsyncClient ASGITransportr openapi)rjrrr\r^r`rbrlr rrgre server_namer5s rh from_fastapizFastMCP.from_fastapis> 766666  &"$ &&z3CDDD"  )c222 !   'ci ,_!%-   sF zFFXFFFrjbackend}Client[ClientTransportT] | ClientTransport | FastMCP[Any] | FastMCP1Server | AnyUrl | Path | MCPConfig | dict[str, Any] | strr^c vtjjrtjdt 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`rVrW)rrrYrZrqr% create_proxy)rjrvrs rhr5zFastMCP.as_proxy sO6   0  MT)     G00x000rjc~|j}||dtjdS|d|dtjdS)N-rV)rksecrets token_hex)rjr class_names rhr zFastMCP.generate_name' sT\ < 997#4Q#7#799 9 @@4@@'*;A*>*>@@ @rj)NN),rrrrrrrrrrrrrrrrrrrrrrrrrrrrdrrrrrrrrrrrrrrrr)rcr)rcr)rrrcr)rcr#)rcr=)r'r(r)r*rcr)rr8rcr)r5r>r4rrcr)rr7rcr7)rcr?)rPrDrcr)rSrrTrLrcr)r\rrcr)r`rdrcrar)rrrr~rcr)r`rdrcr)rrrr~rcr)r`rdrcr)rrrr~rcr)r`rdrcr)rrrr~rcr) rrrrrr~r`rdrrrcrI) rrrrrr~r`rdrrArcr) rrrrrr~r`rdrrrcr) rrrr~r`rdrrrcr0) rrrr~r`rdrrArcr) rrrr~r`rdrrrcr) rrrrrr~r`rdrrrcr-) rrrrrr~r`rdrrrcr)rrrcrH)rrrrrcr) rrorrrrr rr rrrr rr rrrr rrrrrrrrrrrrcro) rrrrrrr rr rrrr rr rrrr rrrrrrrrrrrrcr) rrrrrrr rr rrrr rr rrrr rrrrrrrrrrrrcr)rr"rcr#)rr1rcr1)rrrrrrr rr rrrr(rr rrr)rrrrrrrrrcr)rr,rcr,)rrorrrrr rr rrrr rrrrrrrrcro)rrrrrrr rr rrrr rrrrrrrrcr)rrrrrrr rr rrrr rrrrrrrrcr3)NNNN) rrr4rr5rr6r7r8rrcr)rrr8rrcr)NrYNNNNNT)rZrrer[rrr\r]r^r_r`rarbr7r rrcrdrrrcr )NNNNNNN)rrrrr\r]r^r_r`rarbr7rlrr rrrrcr )rvrwrrrcr^)rrrcr)6rkrlrmrrpropertyrrsetterrrrr&r/r1rr>rGrr[r^rHrrrIrrrJrrrKrrrrrrrrrQrr%r'rr.rrDrX classmethodrkrur5r  __classcell__)rs@rhrrse  #'I -1"&-1$(26/3157;<@15*.$(/3%)!4837JN:>/I I I I I I I I V7777%%%X%---X-....(((X(,,,X,000X0  $ $ $X $ $ $ $ $++++DF<<<<<<<<     0      :++++(GGGG"    :>--------`8<@8<4A4A4A4A4A4A4An)-00000000f7;@7;0E0E0E0E0E0E0Ef)-))))))))X7;@7;4M4M4M4M4M4M4Ml<@%%%%%%%%P8<@8<0C0C0C0C0C0C0Cd,0 '+#X,0) '+# )))))X),0@P '+#%)@P@P@P@P@P@PD '+# X '+# )))))X)'+#%) OWOWOWOWOWOWb,0 '+#X,0) '+# )))))X),0JV '+#%)JVJVJVJVJVJVX 3 3 3 3:  $( "&-1 $9??C)-&*8<)- $37#X("& $( "&-1 $9??C)-&*8<)- $37#X,04a $( "&-1 $9??C)-&*8<)- $37#aaaaaaF ; ; ; ; ; ; ; ; $( "&-1 $ $;?&*8<)-37uuuuuun 7 7 7 7  $( "&-1 $&*)-37     X "&  $( "&-1 $&*)-37     X "04b  $( "&-1 $&*)-37b b b b b b N!% $,0! e?e?e?e?e?T"aIaIaIaIaIF,0$,0156:+/ $ $0@0@0@0@[0@d ,0156:+/59 $4G4G4G4G[4Gl"1"1"1["1HAAAA[AAAAArjrtargetrwrrr^c <ddlm}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_factoryrn)r@r^r)rrr^rrs rhryry6 sfV ,+F33N <  %    rj)rrrcr)rcr)rrHrcrd)rrrcr)rrrcr)rrwrrrcr^)r __future__rrloggingrer|rZcollections.abcrrrr contextlibrr dataclassesr functoolsr pathlibr typingr rrrrrrr mcp.typesrwkey_value.aio.adapters.pydanticrkey_value.aio.protocolsrkey_value.aio.stores.memoryrmcp.server.lowlevel.serverrmcp.shared.exceptionsrrrrrpydanticrrrstarlette.routingrtyping_extensionsr rfastmcp.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/r0fastmcp.resources.templater1fastmcp.server.authr2r3r4r5fastmcp.server.lifespanr6fastmcp.server.low_levelr7fastmcp.server.middlewarer8r9fastmcp.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_transformrLfastmcp.utilities.componentsrMrNfastmcp.utilities.loggingrOfastmcp.utilities.typesrPrQrRfastmcp.utilities.versionsrSrTfastmcp.clientrUfastmcp.client.clientrVfastmcp.client.samplingrWfastmcp.client.transportsrXrY fastmcp.server.providers.openapirZOpenAPIComponentFnr[r\OpenAPIRouteMapFnr@r^rkrFilterr` getLogger addFilterrorrr TransportcompilerHrrrrrrrrryrnrjrhrs;;;""""""   PPPPPPPPPPPPPPPPPP ;;;;;;111111333333666666****** ??????''''''""""""                    )(((((""""""------::::::;;;;;;;;777777UUUUUUUUUUUU,,,,,,333333CCCCCCCCSSSSSSSSSS<<<<<<<<@@@@@@<<<<<<<<000000VUUUUUUUJJJJJJ////////444444<<<<<<JJJJJJJJ000000EEEEEEEEEE <%%%%%%444444777777KKKKKKKKRRRRRR999999PPPPPP;;;;;; H   FFFFF7>FFF .//99  "" GCxS)***@A# E# E#]#/ # u # p #s# !#T#8#<#:#A#Y#O# g!#(      = > bj-..  "=o"NN ''''&!!!!42      0! W AW AW AW AW A O W AW AW A~@444444rj