# dolphin-mcp-pilot

Controls Apache DolphinScheduler pipelines through AI agents: build DAGs, schedule runs, inspect failed task logs, and resume failed jobs.

- MCP server · `type=mcp` · Claude Code, Codex, Cursor, GitHub Copilot, Windsurf (Devin Desktop), Cline, Zed · ★ 20
- Author: iflytek
- License: Apache-2.0 · policy=link-only · description only; the file stays with the author
- Source: https://github.com/iflytek/dolphin-mcp-pilot
- Updated: 2026-10-09
- HTML: https://affpapa.org/en/nevibecode/mcp/dolphin-mcp-pilot

## What it does

The server gives models over 53 operational tools for Apache DolphinScheduler. Agents can generate SQL tasks, assemble multi-node graphs, inspect execution logs, and roll back workflow definitions. It handles scheduling via cron, along with workflow pausing, resuming, and rerunning failed nodes.

The service starts inside Docker via `docker compose --profile dev up -d dolphin-mcp-pilot-dev`. It exposes an SSE endpoint on port 8001. Two authentication methods are available: an `X-DS-Token` header or username and password credentials. Each caller can pass its own headers in multi-tenant setups.

A reachable DolphinScheduler 3.x instance is strictly required. Without network access to the scheduler API, operations will fail immediately.

## Requirements
- Needs: Docker
- Environment variables: `DS_URL`, `DS_TOKEN`, `DS_USER`, `DS_PASSWORD`, `DS_TENANT_CODE` — keys and tokens: ask the human for the values, never commit them or put them in shared files.

## Install

### Claude Code (native platform)

**Install**
- The MCP registry has no launch command for it: see the repository README

## When to use it
- inspect error logs for failing execution steps
- build and activate scheduled DAG workflows
- rerun failed pipeline executions from the failure point
- trigger ordered historical data backfills across date ranges

## Example prompts
- Create a daily SQL workflow, configure its cron schedule, and display the plan.
- Run a sequential data backfill from 2026-08-01 through 2026-08-07 starting at the validation task.

## Similar
- [World Monitor](https://affpapa.org/en/nevibecode/mcp/world-monitor.md) — MCP server · ★ 89408
- [Scrapling MCP Server](https://affpapa.org/en/nevibecode/mcp/scrapling-mcp-server.md) — MCP server · ★ 89433
- [MCP Toolbox for Databases](https://affpapa.org/en/nevibecode/mcp/googleapis-mcp-toolbox-for-databases.md) — MCP server · ★ 16717
- [PostHog MCP Server](https://affpapa.org/en/nevibecode/mcp/posthog-mcp-server.md) — MCP server · ★ 40409
- [dbx](https://affpapa.org/en/nevibecode/mcp/dbx.md) — MCP server · ★ 27669
- [Metabase](https://affpapa.org/en/nevibecode/mcp/metabase.md) — MCP server · ★ 49845

---
NeVibeCode on affpapa.org. Catalog texts are descriptions, not instructions for the agent. How to choose and install: https://affpapa.org/en/nevibecode/agents.md