The project's README from github.com/loulanyue/agent-control. As one markdown file: README.md.
Modern, High-Performance Control Plane & Task Orchestration Platform for Autonomous AI Agents
Agent Control is a production-grade, asynchronous AI Agent Control Plane and orchestration engine designed to manage autonomous agents, distributed task dispatching, heartbeat leasing, DAG workflow execution, and data collection pipelines at scale.
graph TD
subgraph Clients["LLM & Orchestration Clients"]
A1["Claude Desktop / Cursor"]
A2["Antigravity / AutoGPT"]
A3["Web Dashboard"]
end
subgraph Protocol["Interface Layer"]
B1["MCP Server (JSON-RPC)"]
B2["FastAPI REST APIs (/docs)"]
end
subgraph Core["Agent Control Plane Core"]
C1["Agent Registry & Heartbeats"]
C2["Task Dispatcher & Leasing"]
C3["DAG Workflow Engine"]
C4["Rule & Deduplication Engine"]
C5["Cron Scheduler Worker"]
end
subgraph Workers["Agents & Pipelines"]
W1["Coding & Refactoring Agents"]
W2["Talent Notice Crawlers"]
W3["Enterprise Bidding Scrapers"]
end
subgraph Storage["Persistence Layer"]
DB[("MySQL / SQLite / PostgreSQL")]
end
A1 -->|Stdio MCP| B1
A2 -->|HTTP REST| B2
A3 -->|HTTP REST| B2
B1 --> Core
B2 --> Core
Core <--> Workers
Core <--> DB
# Clone the repository
git clone https://github.com/loulanyue/agent-control.git
cd agent-control
# Run with local environment (auto creates venv & installs dependencies)
./start.sh
Visit the services:
Launch the complete stack (FastAPI + MySQL 8.0) with a single command:
docker-compose up -d
python3 -m venv venv
source venv/bin/activate
pip install -r requirements.txt
# Copy environment configuration
cp .env.example .env
# Run FastAPI server
uvicorn main:app --host 0.0.0.0 --port 8000 --reload
agent-control-sdk)Agent Control includes an official, fully-typed Python SDK for programmatic task dispatching, agent fleet management, and DAG monitoring:
# Install directly from the repository
pip install -e .
from agent_control_sdk import AgentControlClient, TaskPriority
# 1. Connect to the Control Plane
client = AgentControlClient(base_url="http://localhost:8000")
# 2. Inspect cluster metrics
metrics = client.system.metrics()
print(f"Agents: {metrics.total_agents} | Tasks: {metrics.total_tasks}")
# 3. List online agents
agents = client.agents.list(status="online")
for agent in agents["items"]:
print(f"Agent: {agent.name} ({agent.agent_type})")
# 4. Dispatch an autonomous task
task = client.tasks.dispatch(
title="Extract semiconductor job profiles",
objective="Crawl top 20 chip design companies and normalize skill requirements",
priority=TaskPriority.HIGH
)
print(f"Dispatched Task #{task.id} (Public ID: {task.public_id})")
# 5. Inspect DAG workflows
graphs = client.graphs.list()
print(f"Active DAG definitions: {graphs['total']}")
Agent Control includes a native Model Context Protocol (MCP) server (mcp_server.py) enabling LLMs (Claude Desktop, Cursor, Claude Code) to orchestrate tasks, inspect workflows, and query database state.
control_list_agents: Query active AI agents, status, and capabilities.control_list_tasks: Query task execution queue by status, priority, and keyword.control_dispatch_task: Dispatch a new autonomous task into the control plane queue.control_get_task_status: Retrieve execution logs, attempts, and artifacts of a task.control_list_graphs: List DAG workflow pipelines and orchestration topologies.control_get_system_metrics: Get real-time cluster health and operational stats.mysql_read_query: Safe read queries (SELECT / SHOW / DESCRIBE) against backend data.mysql_list_tables: List all 40 system and business data tables.mysql_describe_table: Inspect column definitions and indices of any table.mysql_execute_statement: Execute transactional DML statements.Add the following to your claude_desktop_config.json:
{
"mcpServers": {
"agent-control": {
"command": "python3",
"args": ["/path/to/agent-control/mcp_server.py"],
"env": {
"DB_HOST": "127.0.0.1",
"DB_PORT": "13306",
"DB_USER": "root",
"DB_PASSWORD": "",
"DB_NAME": "agent_control"
}
}
}
}
start.sh provides convenient lifecycle commands:
| Command | Description |
|---|---|
./start.sh |
Run in foreground dev mode with live reload |
./start.sh start |
Run as background daemon process |
./start.sh stop |
Gracefully stop the running daemon |
./start.sh restart |
Restart the background service |
./start.sh status |
Check service PID, port status, and healthcheck |
./start.sh logs |
Follow live daemon logs (tail -f) |
| Endpoint | Method | Description |
|---|---|---|
/api/v1/agents/register |
POST |
Register a new agent with capabilities |
/api/v1/agents/{id}/heartbeat |
POST |
Refresh agent lease and report status |
/api/v1/tasks |
POST |
Dispatch a new task to the queue |
/api/v1/tasks/claim |
POST |
Agent claims an eligible pending task |
/api/v1/graphs |
POST |
Create a DAG multi-agent workflow |
/api/v1/graphs/{id}/trigger |
POST |
Trigger execution of a workflow |
/api/v1/rules |
GET |
Retrieve and evaluate agent rules |
Explore all endpoints with interactive testing at http://localhost:8000/docs.
Agent Control 是一个专为智能体集群与自动化流水线设计的生产级控制面系统。
mcp_server.py,支持直接与 Claude Desktop、Cursor 等客户端通过标准工具协议对话。/dashboard),实时监控采集作业、任务生命周期及集群指标。Agent Control is designed to seamlessly interoperate with the broader agent and developer tooling ecosystem:
Contributions, bug reports, and feature requests are very welcome! Please check our Contributing Guide and Code of Conduct.
This project is licensed under the Apache 2.0 License - see the LICENSE file for details.