+ Q(iG@Rt^RIHt^RIt^RIHt^RIHtHtH t H t H t ^RI t ]'d^RIHt^RIHt^RIHt^RIt^RIt^RI HtHt^R I Ht^R IHtHtHtHtHtHt^R I H!t!^R I"H#t#^R I$H%t%^RI&H't'H(t(^RI)H*t*!RR]PV4t,!RR]PV4t-!RR]*4t.ROt.RRlt/R#)z2Base classes and interfaces for FastMCP resources.) annotationsN)Callable) TYPE_CHECKING AnnotatedAnyClassVaroverload)Docket) ExecutionFunctionResource) AnnotationsIcon)Resource)AnyUrl ConfigDictFieldUrlConstraintsfield_validatormodel_validator)SkipJsonSchema)Self) AuthCheck) TaskConfigTaskMeta)FastMCPComponentcja]tRt^%t$RtR]R&RtR]R&RtR]R&RR V3R llltR R lt R t V;t #)ResourceContenta.Wrapper for resource content with optional MIME type and metadata. Accepts any value for content - strings and bytes pass through directly, other types (dict, list, BaseModel, etc.) are automatically JSON-serialized. Example: ```python from fastmcp.resources import ResourceContent # String content ResourceContent("plain text") # Binary content ResourceContent(b"binary data", mime_type="application/octet-stream") # Auto-serialized to JSON ResourceContent({"key": "value"}) ResourceContent(["a", "b", "c"]) ``` z str | bytescontentN str | None mime_typedict[str, Any] | Nonemetac$V^8dQhRRRRRR/#)rrr rr"r!)formats"`/Users/agent/.openclaw/workspace/venv/lib/python3.14/site-packages/fastmcp/resources/resource.py __annotate__ResourceContent.__annotate__?s-UUUU$ Uc *<\V\4'dTpT;'gRpM[\V\4'dTpT;'gRpM6\P!V\R7P 4pT;'gRp\ SV`WBVR7R#)uCreate ResourceContent with automatic serialization. Args: content: The content value. str and bytes pass through directly. Other types (dict, list, BaseModel) are JSON-serialized. mime_type: Optional MIME type. Defaults based on content type: str → "text/plain", bytes → "application/octet-stream", other → "application/json" meta: Optional metadata dictionary. text/plainapplication/octet-stream)fallbackzapplication/json)rr r"N) isinstancestrbytes pydantic_coreto_jsondecodesuper__init__)selfrr r"normalized_content __class__s&&&& r'r6ResourceContent.__init__?s gs # #.5 !11\I  ' '!( !??%?I"/!6!6w!M!T!T!V !77%7I !3tTr*c V^8dQhRRRR/#)r$uri AnyUrl | strreturnz?mcp.types.TextResourceContents | mcp.types.BlobResourceContentsr%)r&s"r'r(r)\s Hr*c 6\VP\4'dm\PP \V\4'd \ V4MTVPVP;'gRVPR7#\PP\V\4'd \ V4MT\P!VP4P4VP;'gRVPR7#)zConvert to MCP resource contents type. Args: uri: The URI of the resource (required by MCP types) Returns: TextResourceContents for str content, BlobResourceContents for bytes r,)r<textmimeType_metar-)r<blobrArB) r/rr0mcptypesTextResourceContentsrr r"BlobResourceContentsbase64 b64encoder4)r7r<s&&r'to_mcp_resource_contents(ResourceContent.to_mcp_resource_contents\s dllC ( (9911#-c3#7#7F3KS\\77<ii 2 9911#-c3#7#7F3KS%%dll3::<EE+Eii 2 r*r%)NN) __name__ __module__ __qualname____firstlineno____doc____annotations__r r"r6rJ__static_attributes__ __classcell__r9s@r'rr%s;* Iz "&D &UU:r*rcra]tRt^wt$RtR]R&RtR]R&RRV3Rlllt]R R l4t R R lt R t V;t #)ResourceResulta*Canonical result type for resource reads. Provides explicit control over resource responses: multiple content items, per-item MIME types, and metadata at both the item and result level. Accepts: - str: Wrapped as single ResourceContent (text/plain) - bytes: Wrapped as single ResourceContent (application/octet-stream) - list[ResourceContent]: Used directly for multiple items or custom MIME types Example: ```python from fastmcp import FastMCP from fastmcp.resources import ResourceResult, ResourceContent mcp = FastMCP() # Simple string content @mcp.resource("data://simple") def get_simple() -> ResourceResult: return ResourceResult("hello world") # Multiple items with custom MIME types @mcp.resource("data://items") def get_items() -> ResourceResult: return ResourceResult( contents=[ ResourceContent({"key": "value"}), # auto-serialized to JSON ResourceContent(b"binary data"), ], meta={"count": 2} ) ``` list[ResourceContent]contentsNr!r"c V^8dQhRRRR/#)r$rX#str | bytes | list[ResourceContent]r"r!r%)r&s"r'r(ResourceResult.__annotate__s 9 95 9$ 9r*c J<VPV4p\SV` W2R7R#)zCreate ResourceResult. Args: contents: String, bytes, or list of ResourceContent objects. meta: Optional metadata about the resource result. )rXr"N)_normalize_contentsr5r6)r7rXr" normalizedr9s&&& r'r6ResourceResult.__init__s%--h7  *8r*c V^8dQhRRRR/#)r$rXrZr>rWr%)r&s"r'r(r[s  5  r*c  \V\4'd \V4.#\V\4'd \V4.#\V\4'dV\ V4FDwr\V\4'dK\ RV R\V4P RV: R24h V#\ R\V4P 24h)z)Normalize input to list[ResourceContent].z contents[z] must be ResourceContent, got z. Use ResourceContent(z) to wrap the value.z;contents must be str, bytes, or list[ResourceContent], got ) r/r0rr1list enumerate TypeErrortyperL)rXiitems& r'r]"ResourceResult._normalize_contentss h $ $#H-. . h & &#H-. . h % %$X.!$88##A3&Ed4jFYFYEZ[//3h6JL/ OI$x.JaJaIb c  r*c V^8dQhRRRR/#)r$r<r=r>zmcp.types.ReadResourceResultr%)r&s"r'r(r[s     2N  r*c VPUu.uFq"PV4NK pp\PP VVP R7#uupi)zConvert to MCP ReadResourceResult. Args: uri: The URI of the resource (required by MCP types) Returns: MCP ReadResourceResult with converted contents )rXrB)rXrJrDrEReadResourceResultr")r7r<rg mcp_contentss&& r' to_mcp_resultResourceResult.to_mcp_resultsSHL}}U}t55c:} Uyy++!)),  VsAr%N) rLrMrNrOrPrQr"r6 staticmethodr]rmrRrSrTs@r'rVrVwsD!F$#"&D & 9 9  *   r*rVca]tRt^t$RtRtR]R&]!RR7t] !RRR 7t R ]R &] !R R R 7t R]R&] !RRR 7t R]R&Rt R]R&RtR]R&]RRRRRRRRRRRRRRRRRRRRRR/ RR ll4t]!RR!R"7]R#R$l44t]!R%R"7R&R'l4tR(R)ltR*R+lt]RAR,R-ll4t]R.R/l4tRAR0R1lltR2R3ltR4R5lt]R6R7l4tR8R9ltR:RR;R/R<R=lltR>V3R?lltR@t V;t!#)BrzBase class for all resources.resourcez ClassVar[str] KEY_PREFIXT)validate_default.zURI of the resource)default descriptionz6Annotated[AnyUrl, UrlConstraints(host_required=False)]r<zName of the resourcer0namer,z!MIME type of the resource contentr NzfAnnotated[Annotations | None, Field(description="Optional annotations about the resource's behavior")]rzAnnotated[SkipJsonSchema[AuthCheck | list[AuthCheck] | None], Field(description='Authorization checks for this resource', exclude=True)]authversiontitlerviconstagsr"taskcPV^8dQhRRRRRRRRR RR RR R R RRRRRRRRRRRRR/#)r$fnzCallable[..., Any]r<z str | AnyUrlrxrrzzstr | int | Noner{rvr|zlist[Icon] | Noner r}zset[str] | NonerzAnnotations | Noner"r!r~zbool | TaskConfig | Noneryz"AuthCheck | list[AuthCheck] | Noner>r r%)r&s"r'r(Resource.__annotate__s# # # #  # " # #  # !# # # (# $# '# 1# !# r*c  L^RIHpVP!VVVVVVVVV V V V V R7 #)r ) rr<rxrzr{rvr|r r}rr"r~ry)#fastmcp.resources.function_resourcer from_function)clsrr<rxrzr{rvr|r r}rr"r~ryr s&&&$$$$$$$$$$$ r'rResource.from_functionsC$  --##  r*before)modec V^8dQhRRRR/#)r$r rr>r0r%)r&s"r'r(rsjSr*c V'dV#R#)z&Set default MIME type if not provided.r,r%)rr s&&r'set_default_mime_typeResource.set_default_mime_types  r*aftercV^8dQhRR/#)r$r>rr%)r&s"r'r(rs$r*c VP'dV#VP'd\VP4VnV#\R4h)z*Set default name from URI if not provided.z#Either name or uri must be provided)rxr<r0 ValueErrorr7s&r'set_default_nameResource.set_default_namesF 999   XXXDHH DI BC Cr*cV^8dQhRR/#)r$r>zstr | bytes | ResourceResultr%)r&s"r'r(r#s F F % Fr*c "\R4h5i)zRead the resource content. Subclasses implement this to return resource data. Supported return types: - str: Text content - bytes: Binary content - ResourceResult: Full control over contents and result-level meta z Subclasses must implement read())NotImplementedErrorrs&r'read Resource.read#s""DEEs c V^8dQhRRRR/#)r$ raw_valuerr>rVr%)r&s"r'r(r/s))))r*c \V\4'dV#\V\\34'd,\\ WP VP R7.4#\V4#)aConvert a raw result to ResourceResult. This is used in two contexts: 1. In _read() to convert user function return values to ResourceResult 2. In tasks_result_handler() to convert Docket task results to ResourceResult Handles ResourceResult passthrough and converts raw values using ResourceResult's normalization. When the raw value is a plain string or bytes, the resource's own ``mime_type`` is forwarded so that ``ui://`` resources (and others with non-default MIME types) don't fall back to ``text/plain``. The resource's component-level ``meta`` (e.g. ``ui`` metadata for MCP Apps CSP/permissions) is propagated to each content item so that hosts can read it from the ``resources/read`` response. )r r")r/rVr0r1rr r")r7rs&&r'convert_resultResource.convert_result/sY" i 0 0  i#u . .! nn499UV  i((r*c V^8dQhRRRR/#)r$ task_metaNoner>rVr%)r&s"r'r(rOsHHTH^Hr*c "R#5iror%r7rs&&r'_readResource._readNsEHc V^8dQhRRRR/#)r$rrr>zmcp.types.CreateTaskResultr%)r&s"r'r(rRsQQXQ2LQr*c "R#5iror%rs&&r'rrQsNQrc V^8dQhRRRR/#)r$rzTaskMeta | Noner>z+ResourceResult | mcp.types.CreateTaskResultr%)r&s"r'r(rTs + +( + 4 +r*c "^RIHpV!VRRVR7GRjxL pV'dV#VP4GRjxL pVPV4#L7L5i)aServer entry point that handles task routing. This allows ANY Resource subclass to support background execution by setting task_config.mode to "supported" or "required". The server calls this method instead of read() directly. Args: 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. Subclasses can override this to customize task routing behavior. For example, FastMCPProviderResource overrides to delegate to child middleware without submitting to Docket. )check_background_taskrrN) component task_type argumentsr)fastmcp.server.tasks.routingrrr)r7rr task_resultresults&& r'rrTsY, G1jDI    yy{"""6** #s$AA AAAAAc V^8dQhRRRR/#)r$ overridesrr> SDKResourcer%)r&s"r'r(rvs     r*c \VPRVP4VPRVP4VPRVP4VPRVP 4VPRVP 4VPRVP4VPRVP4VPRVP44R 7#) z'Convert the resource to an SDKResource.rxr<rvrAr{r|rrB)rxr<rvrAr{r|rrB) rgetrxr<rvr r{r|rget_meta)r7rs&,r'to_mcp_resourceResource.to_mcp_resourcevs vtyy1 eTXX.! mT5E5EF]]:t~~>--4--4! mT5E5EF--  r*cV^8dQhRR/#r$r>r0r%)r&s"r'r(rsFF#Fr*c  VPP RVP: RVP: RVP: RVP R2 #)z(uri=z, name=z, description=z, tags=))r9rLr<rxrvr}rs&r'__repr__Resource.__repr__sb..))*%|7499-~^b^n^n]qqxy}zCzCyDDEF Fr*cV^8dQhRR/#rr%)r&s"r'r(rs22S2r*c VP\VP44pT RVP;'gR 2#)z1The globally unique lookup key for this resource.@rw)make_keyr0r<rz)r7base_keys& r'key Resource.keys8==TXX/1T\\//R011r*c V^8dQhRRRR/#)r$docketr r>rr%)r&s"r'r(rs5565d5r*c VPP4'gR#VPVPVP.R7R#)zr r%)r&s"r'r(rs<888 8  8  8 8r*c "T;'g VPpV'dW4R&VP!V3/VB!4GRjxL #L5i)aSchedule this resource for background execution via docket. Args: docket: The Docket instance fn_key: Function lookup key in Docket registry (defaults to self.key) task_key: Redis storage key for the result **kwargs: Additional kwargs passed to docket.add() rN)radd)r7rrrr lookup_keys&&$$, r' add_to_docketResource.add_to_dockets? ''txx $5MZZ 5f57777sAAAAcV^8dQhRR/#)r$r>zdict[str, Any]r%)r&s"r'r(rs  ^ r*c 6<\SV`4RRRR/,#)zfastmcp.component.typerrzfastmcp.provider.type LocalProvider)r5get_span_attributes)r7r9s&r'rResource.get_span_attributess'w*, $j #_0   r*)rxro)"rLrMrNrOrPrsrQr model_configrr<rxr rry classmethodrrrrrrrrrrrpropertyrrrrrRrSrTs@r'rrs' *J *t4LBG!6CC ?b.DED#E7Is      #  # %) # !# #'# $(# !%# !%# +/# '+# *.# 48# # J[x01 '"# F)>HH QQ +D &F22 5 8" 8 $ 8*  r*rc V^8dQhRRRR/#)r$rxr0r>rr%)r&s"r'r(r(sKKcKcKr*cRRRR/pW9dR^RIp^RIpVPP'dVP RV R2\ ^R7^RIHp\W@4#\R\: R V: 24h) z2Deprecated re-exports for backwards compatibility.r rrNz Importing zh from fastmcp.resources.resource is deprecated. Import from fastmcp.resources.function_resource instead.) stacklevel)function_resourcezmodule z has no attribute ) warningsfastmcpsettingsdeprecation_warningswarnDeprecationWarningfastmcp.resourcesrgetattrAttributeErrorrL)rxdeprecated_exportsrrrs& r' __getattr__rs .J  !    0 0 0 MMTF#KL"   8(// 78,.@I JJr*)rrrV)0rP __future__rrHcollections.abcrtypingrrrrr mcp.typesrDrr docket.executionr rr pydanticr2r rrrrrrrrrpydantic.json_schemartyping_extensionsr!fastmcp.server.auth.authorizationrfastmcp.server.tasks.configrrfastmcp.utilities.componentsr BaseModelrrV__all__rr%r*r'rs8" $DD*D'-0"7<9Oh((OdX X''X v_ _ D Kr*