HTTPX auth flow with automatic retry on stale cached credentials. If the OAuth flow fails due to invalid/stale client credentials, cl

Call a sync function in a threadpool to avoid blocking the event loop. Uses anyio.to_thread.run_sync which properly propagates contextvars, m

Check task mode and submit to background if requested. Args: component: The MCP component task_type: Type of task ("tool", "resou

Configure logging for FastMCP. Args: logger: the logger to configure level: the log level to use rich_kwargs: the pa

Try to consume tokens from the bucket. Args: tokens: Number of tokens to consume Returns: True if tokens wer

Create a new function with the same code but without the specified parameters in annotations. This is used to exclude parameters from type a

Helper to create a FastMCP server with OpenAPIProvider.

Create a complete HTML page with FastMCP styling. Args: content: HTML content to place inside the page title: Page title

Create an OAuth proxy with specified storage.

Return an instance of the SSE server app. Args: server: The FastMCP server instance message_path: Path for SSE messages s

Deduplicate components by key, keeping highest version. Groups components by key, selects the highest version from each group, and injects av

Default handler that properly routes server log messages to appropriate log levels.

Extract output schema from OpenAPI responses for use as MCP tool output schema. This function finds the first successful response (200, 201,

Extract trace context from an MCP request meta dict. If already in a valid trace (e.g., from HTTP propagation), the existing trace context is

Format FastMCPInfo as FastMCP-specific JSON. This includes FastMCP-specific fields like tags, enabled, annotations, etc.

Create a FastMCP server from an OpenAPI specification. Args: openapi_spec: OpenAPI schema as a dictionary cl

Generate JSON schema for fastmcp.json files. This is used to create the schema file that IDEs can use for validation and auto-completion.

Get a setting. If the setting contains one or more `__`, it will be treated as a nested setting.

Retrieve the raw result of a completed background task. Sends a 'tasks/result' MCP protocol request over the existing transport. Retu

Get the authorization scope for task isolation. Returns the raw scope identifier for the current access token, or ``None`` when no auth conte

Creates a standardized error response for phue operations.

Context manager to mock AWS Cognito OIDC discovery endpoint.

Create a new mock middleware context.

Register callback for status change notifications. The callback will be invoked when a notifications/tasks/status is received for thi

Parse YAML frontmatter from markdown content. Args: content: Markdown content potentially starting with --- Returns: Tuple o

Prepare a FastMCP project by creating a persistent uv environment. This command creates a persistent uv project with all dependencies installed:

Prepare the Python environment using uv. Args: output_dir: Directory where the persistent uv project will be created.

Registers all methods marked with @mcp_prompt with the FastMCP server. Args: mcp_server: The FastMCP server instance to register

Registers all methods marked with @mcp_resource with the FastMCP server. Args: mcp_server: The FastMCP server instance to registe

Resolve the effective ``by_alias`` setting for serializing *value*. Pydantic's low-level serialization helpers (``to_json``, ``to_jsonable_py

Run an MCP server or connect to a remote one. The server can be specified in several ways: 1. Module approach: "server.py" - runs the module

Run a Python module directly using ``python -m <module>``. When ``-m`` is used, the module manages its own server startup. No server-object d

Set up HTTP routes for enabling/disabling tools, resources, and prompts. Args: server: The FastMCP server instance. path: Base pa

Download all available skills from a server. Args: client: Connected FastMCP client target_dir: Directory where skill folders wil

Validate a hosted CIMD document. Fetches the document from the given URL and validates: - URL is valid CIMD URL (HTTPS, non-root path) -

Verify a bearer token and return access info if valid. This method implements the TokenVerifier protocol by delegating to ou

Get the current FastMCP Context instance. This dependency provides access to the active FastMCP Context for the current MCP operation (tool/r

Create a Task wrapper. Args: client: The FastMCP client task_id: The task identifier immediate_r

Initialize a FastMCPProvider. Args: server: The FastMCP server to wrap.

Initialize the multi-auth provider. Args: server: Optional auth provider (e.g., OAuthProxy) that owns routes and

Apply pagination to items, raising McpError for invalid cursors. If page_size is None, returns all items without pagination.

Convert MCP AudioContent to OpenAI input_audio content part.

Handle MCP 'callTool' requests. Extracts task metadata from MCP request context and passes it explicitly to call_tool(). The

Convert a sequence to a set, defaulting to an empty set if None.

Return secure cookie name for HTTPS, fallback for HTTP development.

Create a default httpx client from the OpenAPI spec's server URL.

Ensure skills are discovered, rediscovering if reload is enabled.

Extract CSRF token from HTML form.

Extract the list of names from a call_tool ToolResult.

Resolves a schema and returns it as a dictionary.

Get the path to the version cache file.

Gets a client instance by calling the sync or async factory.

Get client identifier for rate limiting.

Get the highest version from successful non-None results. Used for versioned components where we want the highest version across all

Fetch key from JWKS with simple caching and SSRF protection.

Get or create a per-token refresh lock, evicting LRU entries when at capacity.

Read the stored hash from tool meta, or compute from app name + tool name.

Build a fixed-length SHA-256 cache key from request-derived input.

Create a tool with a specific version for testing.

Configure *mock_client* to return a successful GitHub user + scopes response.

Read cached version info. Returns: Tuple of (cached_version, cache_timestamp) or (None, 0) if no cache.

Bind a snapshot to the current asyncio context under ``task_id``. Nothing outside this task's context sees it; stale entries left in a reused

Remove a component from unified storage. Args: key: The prefixed key of the component. Raises: KeyError: If

Convert Google GenAI response to CreateMessageResult (no tools).

Internal helper to remove tokens and their associations.

Scan Goose config for MCP server extensions. Goose uses YAML (``~/.config/goose/config.yaml``) with a different schema — MCP servers are defi

Determine if an error should trigger a retry. Checks both the error itself and its ``__cause__``, since FastMCP wraps tool exceptions

Suppress all scanners that read real user config files.

Add a resource template to the server. Args: template: A ResourceTemplate instance to add Returns: The templ

Call a tool by name with the given arguments. Use this to execute tools discovered via search_tools.

Call a single tool registered on this MCP server multiple times with a single request. Each call can include different arguments. Us

Clear all cached clients and force disconnect them.

Compare two version strings. Args: a: First version string (or None). b: Second version string (or None). Returns: -

Create a styled HTML error page for OAuth errors. Args: error_title: The error title (e.g., "OAuth Error", "Authorization Failed")