Convert Anthropic response to CreateMessageResultWithTools.

A proxy whose backend client negotiates the modern era, so the backend can emit an `InputRequiredResult` for the proxy to round-trip.

An SDK MCPServer whose `greet` tool elicits a name via a resolver. At 2026-07-28 the elicitation is delivered as an `InputRequiredResult`.

Run the connect-time protocol negotiation dictated by ``self.mode``. - ``"legacy"``: today's initialize handshake (populates ``initialize_res

Normalize scopes to a space-separated string (or None).

Convert an object schema to the appropriate Python type. Single source of truth for the four object-schema cases, used by both the top-level

Handle MCP 'tools/call' requests. A guard tool (SEP-2322 multi-round-trip) requests client input by returning an ``InputRequiredResul

Generic pagination helper for list operations. Invokes a FastMCP ``_on_*`` list handler (``(ctx, params) -> result``) page by page. T

Parse an mcp_types.CallToolResult into our CallToolResult dataclass. Args: name: Tool name (for schema lookup) result

Serialize a PrefabApp, addressing its peer-tool references by identity. The resolver writes each reference as ``<hash>_<local_name>``, and the

Prepare scopes for upstream token refresh request. Override this method to transform scopes before sending to upstream provider. For

Attach the incoming `_meta` trace context without creating a span. This is what separates `propagation_only` from `off`. Both create no FastM

Convert a scalar to its query-string representation. Booleans are lowercased to match JSON/OpenAPI conventions (true/false) rather than Pytho

Call `call` until it succeeds on a subprocess other than `old_pid`. `psutil.Process(pid).kill()` is asynchronous and crash recovery is transp

Read a backend resource, surfacing a guard ask rather than driving it. Mirrors `ProxyTool.run`: on a modern backend the low-level session is used

Raise ImportError with install instructions if azure-identity is not available.

Reset session state after disconnect or cancellation. Args: full: If True, also resets session_task and nesting_counter.

Resolve a callable's parameter type hints, tolerating partials. ``get_type_hints`` rejects ``functools.partial`` objects (and other non-funct

Resolve JSON Schema reference to target schema.

Wrap a token store in the FastMCP adapter, defaulting to in-memory. Unlike the interactive `OAuth` provider, M2M providers do not warn when using

Text from ReadResourceResult.contents blocks (TextResourceContents).

Set the ``request_ctx``, ``_current_context`` and ``_current_server`` ContextVars from stashed values so a proxy forwarding handler relays to the

Restore the persisted absolute token expiry after a token is reloaded. The inherited initializer reloads the stored token but not its expiry, so

Remove namespace prefix from a name, or None if no match.

Remove namespace from a URI, or None if no match.

Run the method-agnostic (``on_message``/``on_request``) hook pass. ``call_next`` bridges to the real SDK dispatch (request-state boundary,

Convert string to valid Python identifier.

Add a consent binding entry for a transaction. This cookie binds the browser that approved consent to the IdP callback, ensuring a di

Set up a proxy JWT pointing at a valid upstream token, with optional upstream_claims.

Pop `"additionalProperties": false` from every migrated schema, asserting it's there. FastMCP's generated tool schemas declare `"additionalProper

Wall-clock TTL for a task's Redis metadata keys. Docket's ``execution_ttl`` plus a buffer (matching task creation), so a key written or refre

The best available error message for a failed task.

Lowercase, split on non-alphanumeric, filter short tokens.

Apply namespace prefix to a name.

An in-memory transport whose ``server/discover`` returns ``body`` verbatim.

Truncate text to fit within max_size and wrap in ToolResult.

Refresh the upstream token transparently and update storage. Called during load_access_token when the upstream token has expired but

Poll until a process has exited, raising if it's still alive after timeout.

Enumerate all prefab tools across the server's providers (sync walk of _components).

Collect every ``toolCall`` action object in a payload tree.

Read the HTTP headers snapshotted at task submission from inside a worker.

Write version info to cache.

Write the consent binding map to a signed cookie.

Take the per-task update lock, or return False if one is already held. Serializes concurrent ``tasks/update`` calls for a task so two racing

Wait for the per-task update lock, up to ``timeout`` seconds. ``tasks/cancel`` uses this to serialize with an in-flight ``tasks/update``: it

Add a prompt to this provider's storage. Accepts either a Prompt object or a decorated function with __fastmcp__ metadata.

Add a resource to this provider's storage. Accepts either a Resource/ResourceTemplate object or a decorated function with __fastmcp__ metadat

Add a tool to this provider's storage. Accepts either a Tool object or a decorated function with __fastmcp__ metadata.

Preview a FastMCPApp UI in the browser. Starts the MCP server from SERVER_SPEC on --mcp-port, launches a local dev UI on --dev-port with a to

Assert that a notification was sent a specific number of times.

Start OAuth transaction and redirect to Azure AD. Override parent's authorize method to filter out the 'resource' parameter which is

The ASGI app the conformance suite is run against. Shared by the pytest fixture and the `__main__` entry point so both exercise the same conf

Call a tool on the server. Unlike call_tool_mcp, this method raises a ToolError if the tool call results in an error. Args:

Run a `tools/call` with the tasks opt-in bound into the request context.

Request cooperative cancellation of the task via `tasks/cancel`.

Clear this adapter's collection only. Prefers deleting each enumerated key (which leaves the collection usable), and falls back to wh

Drop a leg's outstanding requests and mapping once it has been answered. The answered surfaced keys are never reused (a later leg mints its own),

Wrap a user function's return value in a ResourceResult. Shared by `Resource` and `ResourceTemplate` so both honor the MIME type the componen

Convert a raw result to ResourceResult. This is used in two contexts: 1. In _read() to convert user function return values to Resourc

Convert a raw return value to PromptResult. Accepts: - PromptResult: passed through - str: wrapped as single Message

Create a base Starlette app with common middleware and routes. Args: routes: List of routes to include in the app middleware: Lis

Create a styled HTML consent page for OAuth authorization requests. Args: csp_policy: Content Security Policy override. If No

Create a FastMCP server from FastAPI app with experimental parser.

Create an info box. Args: content: HTML content for the info box is_error: True for error styling, False for normal

Helper to create a FastMCP server with OpenAPIProvider.

Create a status message with icon. Args: message: Status message text is_success: True for success (✓), False for error (✕)

Install an MCP server in Cursor. Args: server_spec: Python file to install, optionally with :object suffix

Delete a value from the state store. Removes from both request-scoped and session-scoped stores.

Generate inline enum schema. Always generates enum pattern: `{"enum": [value, ...]}` Titled enums are handled separately via dict-bas

Extract query parameter names from RFC 6570 `{?param1,param2}` syntax.

Extract the FastMCP component version from a lifted ``_meta`` block.

Always raises an error.