Orchestra MCP Server
Enables interaction with the Orchestra API for managing pipelines, runs, logs, and artifacts through natural language.
README
Orchestra MCP Server
A Model Context Protocol (MCP) server for the Orchestra API. End users can connect directly to Orchestra's hosted MCP endpoint and authenticate with their Orchestra API key.
Quick Start
Use Orchestra's hosted MCP endpoint:
- URL:
https://mcp.getorchestra.io/orchestra - Required header:
Authorization: Bearer <YOUR_ORCHESTRA_API_KEY> - API key location: Orchestra workspace settings
Available Tools
| Tool | Auth required | Purpose | Category |
|---|---|---|---|
validate_pipeline |
No | Check a pipeline definition (JSON object) against the Orchestra schema (POST /pipelines/schema). Does not persist anything. |
Pipeline lifecycle |
list_pipelines |
Yes | List all pipelines for the workspace with latest run metadata (GET /pipelines). |
Pipeline lifecycle |
get_pipeline |
Yes | Fetch a single pipeline by selector (GET /pipeline). |
Pipeline lifecycle |
create_pipeline |
Yes | Create an Orchestra-backed pipeline from a definition object (POST /pipelines). |
Pipeline lifecycle |
update_pipeline |
Yes | Update an Orchestra-backed pipeline by alias (PUT /pipelines/{alias}). Git-backed pipelines cannot be updated here. |
Pipeline lifecycle |
migrate_pipeline |
Yes | Migrate an Orchestra-backed pipeline to git-backed storage (PATCH /pipelines/storage-settings). The YAML must already exist in the repo. |
Pipeline lifecycle |
delete_pipeline |
Yes | Disabled by default. Delete a pipeline by selector (DELETE /pipelines). Set ORCHESTRA_ENABLE_DELETE to expose it. |
Pipeline lifecycle |
import_pipeline |
Yes | Import a pipeline whose YAML lives in a Git repository (POST /pipelines/import). |
Pipeline lifecycle |
start_pipeline |
Yes | Start a run by alias or pipeline ID (POST /pipelines/{alias_or_id}/start). Optionally target a version_number. |
Pipeline running |
get_pipeline_run_status |
Yes | Poll a single pipeline run’s status. | Pipeline running |
cancel_pipeline_run |
Yes | Request cancellation of a pipeline run. | Pipeline running |
get_pipeline_run_lineage_url |
No | Return the UI URL for a pipeline run’s lineage graph (derived from ORCHESTRA_ENV). |
Pipeline running |
list_pipeline_runs |
Yes | List runs with optional time range plus comma-separated status and ID filters. | Observability |
list_task_runs |
Yes | List task runs with optional comma-separated filters (including integration). | Observability |
list_operations |
Yes | List operations with optional comma-separated filters. | Observability |
list_assets |
Yes | List data assets with optional comma-separated type and integration filters. | Observability |
list_task_run_logs |
Yes | List log filenames for a task run. | Logs and artifacts |
download_task_run_log |
Yes | Download a log file (optional HTTP Range); content is base64-encoded in the result. | Logs and artifacts |
list_task_run_artifacts |
Yes | List artifact filenames for a task run. | Logs and artifacts |
download_task_run_artifact |
Yes | Download an artifact file; content is base64-encoded in the result. | Logs and artifacts |
Cursor
Add this to .cursor/mcp.json (project) or ~/.cursor/mcp.json (global):
{
"mcpServers": {
"orchestra": {
"url": "https://mcp.getorchestra.io/orchestra",
"headers": {
"Authorization": "Bearer <YOUR_ORCHESTRA_API_KEY>"
}
}
}
}
Claude Code
Add the hosted server with:
claude mcp add --transport http --header "Authorization: Bearer <YOUR_ORCHESTRA_API_KEY>" orchestra https://mcp.getorchestra.io/orchestra
Other MCP clients
Any MCP client that supports remote HTTP/SSE servers can connect with this shape:
{
"mcpServers": {
"orchestra": {
"url": "https://mcp.getorchestra.io/orchestra",
"headers": {
"Authorization": "Bearer <YOUR_ORCHESTRA_API_KEY>"
}
}
}
}
Managing Multiple Workspaces
If you need to connect to multiple Orchestra workspaces, you can set up separate MCP server connections with workspace-specific API keys:
{
"mcpServers": {
"orchestra-data-quality-tests": {
"url": "https://mcp.getorchestra.io/orchestra",
"headers": {
"Authorization": "Bearer <DATA_QUALITY_WORKSPACE_API_KEY>"
}
},
"orchestra-sales-integrations": {
"url": "https://mcp.getorchestra.io/orchestra",
"headers": {
"Authorization": "Bearer <SALES_WORKSPACE_API_KEY>"
}
}
}
}
Run Locally
This section discusses how to run the MCP server locally, and is mainly intended for contributors.
Prerequisites
- Python 3.10 or higher
- uv package manager
- Orchestra API key
Install dependencies
# Install uv if you haven't already
curl -LsSf https://astral.sh/uv/install.sh | sh
# Install project dependencies
uv sync
Set API key
export ORCHESTRA_API_KEY="your-orchestra-api-key"
(Optional) Select environment for local runs
For local development, the server defaults to app. You can override it with ORCHESTRA_ENV:
export ORCHESTRA_ENV="dev"
Valid values:
app(default)stagedev
(Optional) Enable destructive pipeline deletion
By default, the MCP delete_pipeline tool is not registered to avoid accidental destructive actions.
To expose it, set ORCHESTRA_ENABLE_DELETE before starting the server:
export ORCHESTRA_ENABLE_DELETE="true"
Only the following values are recognized:
"true""TRUE""1"
Run the server
python -m orchestramcp.server
Or with FastMCP CLI:
uv run fastmcp run orchestramcp/server.py
Development
- Run
uv run pytestto run tests. - Run
uv run ruff check .anduv run ruff format .to check and format code.
PRs to main will trigger CI checks in GitHub, main branch merges release to the dev & stage environments, and Github releases relase to the production environment.
推荐服务器
Baidu Map
百度地图核心API现已全面兼容MCP协议,是国内首家兼容MCP协议的地图服务商。
Playwright MCP Server
一个模型上下文协议服务器,它使大型语言模型能够通过结构化的可访问性快照与网页进行交互,而无需视觉模型或屏幕截图。
Magic Component Platform (MCP)
一个由人工智能驱动的工具,可以从自然语言描述生成现代化的用户界面组件,并与流行的集成开发环境(IDE)集成,从而简化用户界面开发流程。
Audiense Insights MCP Server
通过模型上下文协议启用与 Audiense Insights 账户的交互,从而促进营销洞察和受众数据的提取和分析,包括人口统计信息、行为和影响者互动。
VeyraX
一个单一的 MCP 工具,连接你所有喜爱的工具:Gmail、日历以及其他 40 多个工具。
graphlit-mcp-server
模型上下文协议 (MCP) 服务器实现了 MCP 客户端与 Graphlit 服务之间的集成。 除了网络爬取之外,还可以将任何内容(从 Slack 到 Gmail 再到播客订阅源)导入到 Graphlit 项目中,然后从 MCP 客户端检索相关内容。
Kagi MCP Server
一个 MCP 服务器,集成了 Kagi 搜索功能和 Claude AI,使 Claude 能够在回答需要最新信息的问题时执行实时网络搜索。
e2b-mcp-server
使用 MCP 通过 e2b 运行代码。
Neon MCP Server
用于与 Neon 管理 API 和数据库交互的 MCP 服务器
Exa MCP Server
模型上下文协议(MCP)服务器允许像 Claude 这样的 AI 助手使用 Exa AI 搜索 API 进行网络搜索。这种设置允许 AI 模型以安全和受控的方式获取实时的网络信息。