Prefect

Gerencie e observe fluxos de trabalho do Prefect por meio de linguagem natural.

Documentação

Descontinuado em 27-Nov-2025

Eu pessoalmente movi meus esforços para um MCP mais genérico baseado em especificação OpenAPI: https://github.com/allen-munsch/yas-mcp

Além disso, na verdade existe um lançamento beta oficial da Prefect aqui: https://pypi.org/project/prefect-mcp/

Servidor MCP Prefect

Uma implementação de servidor Model Context Protocol (MCP) para Prefect, permitindo que assistentes de IA interajam com o Prefect por meio de linguagem natural.

Nota: O servidor MCP oficial do Prefect está disponível aqui. Esta é uma implementação da comunidade.

🚀 Início Rápido

docker compose up

📦 Instalação

Instalação via pip

pip install mcp-prefect

A partir do Código-Fonte

git clone https://github.com/allen-munsch/mcp-prefect
cd mcp-prefect
pip install -e .

Execução Manual

PREFECT_API_URL=http://localhost:4200/api \
PREFECT_API_KEY=your_api_key_here \
MCP_PORT=8000 \
python -m mcp_prefect.main --transport http

🛠️ Recursos


╭────────────────────────────────────────────────────────────────────────────╮
│                                                                            │
│        _ __ ___  _____           __  __  _____________    ____    ____     │
│       _ __ ___ .'____/___ ______/ /_/  |/  / ____/ __ \  |___ \  / __ \    │
│      _ __ ___ / /_  / __ `/ ___/ __/ /|_/ / /   / /_/ /  ___/ / / / / /    │
│     _ __ ___ / __/ / /_/ (__  ) /_/ /  / / /___/ ____/  /  __/_/ /_/ /     │
│    _ __ ___ /_/    \____/____/\__/_/  /_/\____/_/      /_____(*)____/      │
│                                                                            │
│                                                                            │
│                                FastMCP  2.0                                │
│                                                                            │
│                                                                            │
│                 🖥️  Server name:     MCP Prefect 3.6.1                      │
│                 📦 Transport:       STDIO                                  │
│                                                                            │
│                 🏎️  FastMCP version: 2.12.3                                 │
│                 🤝 MCP SDK version: 1.14.1                                 │
│                                                                            │
│                 📚 Docs:            https://gofastmcp.com                  │
│                 🚀 Deploy:          https://fastmcp.cloud                  │
│                                                                            │
╰────────────────────────────────────────────────────────────────────────────╯


[11/11/25 02:08:06] INFO     Starting MCP server 'MCP Prefect 3.6.1' with transport 'stdio'                                                                                     server.py:1495
✅ Initialized successfully
Server: MCP Prefect 3.6.1 1.14.1

🔄 Listing tools...

🎯 FOUND 64 TOOLS:
================================================================================

📂 ARTIFACT (6 tools)
  🔧 create_artifact
  🔧 delete_artifact
  🔧 get_artifact
  🔧 get_artifacts
  🔧 get_latest_artifacts
  🔧 update_artifact

📂 AUTOMATION (7 tools)
  🔧 create_automation
  🔧 delete_automation
  🔧 get_automation
  🔧 get_automations
  🔧 pause_automation
  🔧 resume_automation
  🔧 update_automation

📂 BLOCK (5 tools)
  🔧 delete_block_document
  🔧 get_block_document
  🔧 get_block_documents
  🔧 get_block_type
  🔧 get_block_types

📂 DEPLOYMENT (8 tools)
  🔧 delete_deployment
  🔧 get_deployment
  🔧 get_deployment_schedule
  🔧 get_deployments
  🔧 pause_deployment_schedule
  🔧 resume_deployment_schedule
  🔧 set_deployment_schedule
  🔧 update_deployment

📂 FLOW (13 tools)
  🔧 cancel_flow_run
  🔧 create_flow_run_from_deployment
  🔧 delete_flow
  🔧 delete_flow_run
  🔧 get_flow
  🔧 get_flow_run
  🔧 get_flow_run_logs
  🔧 get_flow_runs
  🔧 get_flow_runs_by_flow
  🔧 get_flows
  🔧 get_task_runs_by_flow_run
  🔧 restart_flow_run
  🔧 set_flow_run_state

📂 LOG (2 tools)
  🔧 create_log
  🔧 get_logs

📂 OTHER (1 tools)
  🔧 get_health

📂 TASK (4 tools)
  🔧 get_task_run
  🔧 get_task_run_logs
  🔧 get_task_runs
  🔧 set_task_run_state

📂 VARIABLE (5 tools)
  🔧 create_variable
  🔧 delete_variable
  🔧 get_variable
  🔧 get_variables
  🔧 update_variable

📂 WORK (13 tools)
  🔧 create_work_queue
  🔧 delete_work_queue
  🔧 get_current_workspace
  🔧 get_work_queue
  🔧 get_work_queue_by_name
  🔧 get_work_queue_runs
  🔧 get_work_queues
  🔧 get_workspace
  🔧 get_workspace_by_handle
  🔧 get_workspaces
  🔧 pause_work_queue
  🔧 resume_work_queue
  🔧 update_work_queue

📊 TOTAL: 64 tools across 10 categories

💬 Exemplos de Interações

Assistentes de IA podem ajudar você com:

Gerenciamento de Fluxos

"Mostre-me todos os meus fluxos e o status da última execução"
"Crie uma nova execução de fluxo para o deployment 'data-processing'"
"Qual é o status atual da execução do fluxo 'abc-123'?"

Controle de Deployments

"Pause o agendamento do deployment 'daily-reporting'"
"Atualize o deployment 'etl-pipeline' com novos parâmetros"

Gerenciamento de Infraestrutura

"Liste todos os work pools e seu status atual"
"Crie uma nova fila de trabalho para tarefas de alta prioridade"

Variáveis e Configuração

"Crie uma variável chamada 'api_timeout' com valor 300"
"Mostre-me todas as variáveis que contêm 'config' no nome"

Monitoramento e Depuração

"Obtenha os logs da última execução de fluxo que falhou"
"Mostre-me todas as execuções de tarefas em andamento agora"

🤖 Integração com Plataformas

Claude Desktop

Adicione em claude_desktop_config.json:

{
  "mcpServers": {
    "prefect": {
      "command": "mcp-prefect",
      "args": ["--transport", "stdio"]
    }
  }
}

Cursor MCP

{
  "mcpServers": {
    "prefect": {
      "command": "mcp-prefect",
      "args": ["--transport", "stdio"]
    }
  }
}

Gemini CLI

gemini config set mcp-servers.prefect "mcp-prefect --transport stdio"

Windsurf / Claude Code

{
  "mcpServers": {
    "prefect": {
      "command": "mcp-prefect",
      "args": ["--transport", "stdio"],
      "env": {
        "PREFECT_API_URL": "http://localhost:4200/api",
        "PREFECT_API_KEY": "your_api_key_here"
      }
    }
  }
}

Cliente MCP Genérico

{
  "mcpServers": {
    "prefect": {
      "command": "mcp-prefect",
      "args": ["--transport", "stdio"],
      "env": {
        "PREFECT_API_URL": "http://localhost:4200/api",
        "PREFECT_API_KEY": "your_api_key_here"
      }
    }
  }
}

🧪 Desenvolvimento

Executando Testes

pytest tests/ -v

Compilando a partir do Código-Fonte

git clone https://github.com/allen-munsch/mcp-prefect
cd mcp-prefect
pip install -e .
python -m mcp_prefect