AgentBus

El bus de eventos MCP respaldado por SQLite y la superficie de control para enjambres de agentes heterogéneos.

Cuando Cursor, Claude, Antigravity y agentes de terminal (como Hermes) comparten un espacio de trabajo, normalmente se coordinan a través de archivos frágiles de solo adición (log.md). Eso funciona hasta que necesitas timeouts de SLA, interceptaciones Human-in-the-Loop (HITL), validación estricta de esquemas o RBAC criptográfico.

AgentBus sustituye el «juego del teléfono escacharrado» por un sidecar local: un servidor MCP de Python respaldado por SQLite. Sin bloqueo por el runtime del orquestador. Sin paneles de control pesados en la nube. Solo un pub/sub local ultrarápido para una orquestación de IA de alto nivel.

v0.18.0 (agosto de 2026): migración a MCP Python SDK v2, tras el trabajo de los headless runners, la suspensión/reanudación asíncrona, el wake plane y la entrega resiliente publicados en v0.12–v0.16. Consulta el changelog para ver los detalles de la versión.

Nota: instálalo como okf-agentbus (el comando de CLI sigue siendo agentbus). Extras: [obs,devex,jupyter,sdk].

⚡ El momento «¡Ajá!»: integración sin reiniciar tu trabajo

¿Ya tienes a Aider, OpenHands o agentes personalizados ejecutándose en paneles de tmux? No mates tus sesiones. AgentBus tiene una arquitectura de doble interfaz (MCP + CLI). No necesitas configurar archivos JSON para probarlo hoy. Solo dile a tu agente en ejecución:

"Usa tu terminal para ejecutar agentbus publish --topic okf/handoff --payload '{\"from\":\"grok\",\"to\":\"hermes\",\"summary\":\"Write tests\"}'"

El bus SQLite lo captura al instante, sin que el servidor MCP esté en ejecución. Una vez que la Mission Control TUI te haya convencido, puedes conectar el servidor MCP fuertemente tipado en tu siguiente arranque.

Related MCP server: Hivemind

¿Por qué AgentBus?

Arsenal de funciones (v0.3 - v0.18)

• MCP Python SDK v2 (v0.18): servidor MCP stdio xmigrado conservando el contrato del event store existente.

• Entrega resiliente (v0.16.4): reintentos con backoff y jitter, dead letters cuando se agotan los reintentos y datos resguardados a archivo para la contención de SQLite.

• Suspend/reanudación asíncrona (v0.16): esperas durables y eventos wake correlacionados para que los agentes headless cedan sin sondeo activo.

• Headless runners (v0.15): adaptador opcional para agentes CLI heterogéneos, sincronizados (o corroborables) y ack estructuraron.

• Wake plane y helpers de Go (v0.12-v0.13): workers empaquetados por plataforma, leases de rol, wake ingress y entrega por webhook.

• Cliente asíncrono de Jupyter (v0.11): from agentbus.jupyter import AsyncAgentBus + %agentbus start — ejecución no bloqueante que cede el control al event loop del notebook.

• Cliente TypeScript (v0.11): packages/js/agentbus-client — EventEmitter de Node + spawn de MCP con stdio (@agentbus/agentbus-client, por ahora instalable por ruta).

• God View Mesh (v0.9): observabilidad pasiva del SO + MCP para que los agentes silenciosos también dejen huellas en el bus (system/mcp, system/fs, system/shell, system/monologue).

• Mission Control TUI (v0.8+): un panel Textual controlado por teclado (agentbus monitor). Waterfall de trazas, HITL, panel Wiretap y Late.

• Esquemas Pydantic conectables (v0.7): decoradores code-first @bus.topic para imponer esquemas JSON estrictos estrictos en la capa de inserción.

• Contexto distribuido (v0.6): pasa contexto masivo (como diffs de git) con --attach. Los límites duros de 1 MB evitan que la ventana de contexto explote.

• Observabilidad agéntica (v0.5): linaje nativo parecido de telemetría trace_id y parent_span_id.

• SLA Timeouts y dead-letter (v0.4): previene escortamientos fantasma. Si un agente ignora al swarm, los temporizando los timers envían la carga a okf/dead-letter.

• Swarm RBAC y Droid Proofs (v0.3): tokens criptográficos JWT/UUID garantizan que solo los agentes autorizados publiquen en temas restringidos.

• Password potencial (v0.3): intercepta payloads peligrosos (p. ej., DROP TABLE) y los coloca en PENDING_APPROVAL para su revisión humana desde la TUI.

Instalación

La vía más rápida (instala y auto-configura tus IDEs en un solo paso):

curl -sSL https://raw.githubusercontent.com/onicarps/agentbus/main/install.sh | bash

O manualmente con pip:

pip install -U "okf-agentbus[devex,sdk]"
agentbus init --apply --producer-id my-agent

Cuadernos de Jupyter:

pip install -U "okf-agentbus[jupyter]"

%load_ext agentbus.jupyter
%agentbus start
# or
from agentbus.jupyter import AsyncAgentBus
bus = AsyncAgentBus()  # AGENTBUS_WORKSPACE or cwd
bus.on_event(print)
await bus.start_background(interval=1.0)

TypeScript (desde un checkout del monorepo):

cd packages/js/agentbus-client && npm install && npm test
# set AGENTBUS_WORKSPACE + agentbus on PATH, then use createStdioMcpClient / AgentBus

Inicio rápido y ejemplos

La mejor forma de entender AgentBus es leer nuestros ejemplos listos para copiar y pegar.

Consulta el directorio examples/ con 7 scripts Python impecables y aislados que cubren toda funcionalidad, desde Pub/Sub básico hasta esquemas Pydantic y SLA Timeouts.

# Terminal A — Launch the Mission Control TUI
agentbus monitor

# Terminal B — Publish a handoff
agentbus publish \
  --topic okf/handoff \
  --payload '{"from":"cursor","to":"hermes","summary":"Write tests"}'

God View Observability (v0.9.0):

Sigue agentes silenciosos viendo directamente sus operaciones:

# Intercept MCP tool calls
mcp-serve --wiretap

# Watch file edits and command executions
agentbus watch

# Tail internal agent reasoning logs
agentbus tail

Los eventos fluirán al panelytap TUI como topics system/mcp, system/fs, system/shell y system/monologue.

📦 Aislamiento del workspace (el directorio .agentbus)

AgentBus in the world of workspace isolation (similar a cómo git usa .git o Docker usa docker-compose.yml).

El bus y sus eventos están físicamente acotados al directorio donde los ejecutas. Esto evita que tu swarm rastree todo tu sistema operativo o contamine entre sí tus proyectos.

Cuando entras en una carpeta concreta y ejecutas agentbus init o agentbus up, se crea una base de datos SQLite local .agentbus/events.db específica para ese directorio.

Orquestación del swarm con 1 clic (v0.10.0)

En lugar de abrir manualmente 5 paneles de tmux para iniciar tus agentes y demonios de observabilidad, usa el nuevo orquestador:

cd /path/to/my-project

# 1. Generate a boilerplate .agentbus/swarm.yaml
agentbus up --init

# 2. Boot the swarm (Watchers, Agents, and TUI) in one click
agentbus up

# 3. View running background agents
agentbus ps

# 4. Safely kill the entire swarm
agentbus down

Documentación

Para la documentación arquitectónica completa, ve al directorio docs/.

• Roadmap

• Plan de producto v0.19 y handoff de Swarm entre máquinas

• Esquema MCP

• Proceso de release

Licencia

MIT — consulte LICENSE.