Skip to main content

MCP Server for Prefect

Project description

Prefect MCP Server

A Model Context Protocol (MCP) server implementation for Prefect, allowing AI assistants to interact with Prefect through natural language.

Features

This MCP server provides access to the following Prefect APIs:

  • Flow Management: List, get, and delete flows
  • Flow Run Management: Create, monitor, and control flow runs
  • Deployment Management: Manage deployments and their schedules
  • Task Run Management: Monitor and control task runs
  • Work Queue Management: Create and manage work queues
  • Block Management: Access block types and documents
  • Variable Management: Create and manage variables
  • Workspace Management: Get information about workspaces

Configuration

Set the following environment variables:

export PREFECT_API_URL="http://localhost:4200/api"  # URL of your Prefect API
export PREFECT_API_KEY="your_api_key"               # Your Prefect API key (if using Prefect Cloud)

Usage

Run the MCP server, and prefect:

docker compose up

Example Input

Once connected, an AI assistant can help users interact with Prefect using natural language. Examples:

  • "Show me all my flows"
  • "List all failed flow runs from yesterday"
  • "Trigger the 'data-processing' deployment"
  • "Pause the schedule for the 'daily-reporting' deployment"
  • "What's the status of my last ETL flow run?"

Development

Several of the endpoints have yet to be implemented

Adding New Functions

To add a new function to an existing API:

  1. Add the function to the appropriate module in src/mcp_prefect
  2. Add the function to the get_all_functions() list in the module

To add a new API type:

  1. Add the new type to APIType in enums.py
  2. Create a new module in src/prefect/
  3. Update main.py to include the new API type

Example usage:

{
  "mcpServers": {
    "mcp-prefect": {
      "command": "mcp-prefect",
      "args": [
        "--transport", "sse"
      ],
      "env": {
        "PYTHONPATH": "/path/to/your/project/directory"
      },
      "cwd": "/path/to/your/project/directory"
    }
  }
}

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

mcp_prefect-0.2.3419.tar.gz (134.2 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

mcp_prefect-0.2.3419-py3-none-any.whl (20.9 kB view details)

Uploaded Python 3

File details

Details for the file mcp_prefect-0.2.3419.tar.gz.

File metadata

  • Download URL: mcp_prefect-0.2.3419.tar.gz
  • Upload date:
  • Size: 134.2 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.12.9

File hashes

Hashes for mcp_prefect-0.2.3419.tar.gz
Algorithm Hash digest
SHA256 0e35c38c4ece09ab62dfff3cf81b90bc7e986a4e76f1774d6169e343b3bc7ec1
MD5 26a49e777446a8e129fd8dbe09e7f0e5
BLAKE2b-256 461f417ace470d030e013a2c5e5f9a3cbf439ad1f2c87aaf21d5c38a936e917f

See more details on using hashes here.

File details

Details for the file mcp_prefect-0.2.3419-py3-none-any.whl.

File metadata

  • Download URL: mcp_prefect-0.2.3419-py3-none-any.whl
  • Upload date:
  • Size: 20.9 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.12.9

File hashes

Hashes for mcp_prefect-0.2.3419-py3-none-any.whl
Algorithm Hash digest
SHA256 0e2f89892a5aa6f5ab334db646ce900f4403e78eade6a3d4968f4335c40e8061
MD5 7f7c3c25e1c5fe73ccd2c5a59ca82e30
BLAKE2b-256 f0f7a3d8f3867b5551da023a942e309c5a5e31fcd42096205f6633336d1afbd0

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page