Skip to main content

SQLite-backed MCP event bus and control surface for heterogeneous agent orchestration.

Project description

AgentBus

Test Python License: MIT

The SQLite-Backed MCP Event Bus & Control Surface for Heterogeneous Agent Swarms.

When Cursor, Claude, Antigravity, and Terminal Agents (like Hermes) share a workspace, they usually coordinate through fragile append-only files (log.md). That works until you need SLA timeouts, Human-in-the-Loop (HITL) intercepts, strict schema validation, or cryptographic RBAC.

AgentBus replaces the "Game of Telephone" with a localhost sidecar: a Python MCP server backed by SQLite. No orchestrator runtime lock-in. No heavy cloud dashboard. Just a hyper-fast local pub/sub built for top-tier AI orchestration.

v0.8.0 (July 2026): Now includes the Textual-based Mission Control TUI, Swarm RBAC, SLA Timeouts, Distributed Artifact Context, and Code-First Pydantic Schemas.

Note: Install as okf-agentbus (CLI command remains agentbus).

Why AgentBus?

Alternative Limitation AgentBus
log.md blackboard No schema, race conditions Typed topics, monotonic IDs, advisory locks
LangGraph / CrewAI Same-runtime lock-in Heterogeneous out-of-process clients (IDE + CLI)
LangSmith Cloud-only, backward-looking Local SQLite, forward-looking Execution TUI
Redis pub/sub Extra daemon, complex setup Zero-config SQLite, native stdio MCP

Feature Arsenal (v0.3 - v0.8)

  • Mission Control TUI (v0.8): A rich, keyboard-driven Textual dashboard (agentbus monitor). View live trace waterfalls and approve/reject HITL tasks with a single keystroke.
  • Pluggable Pydantic Schemas (v0.7): Code-first @bus.topic decorators to enforce strict JSON schemas at the insertion layer.
  • Distributed Context (v0.6): Pass massive context (like git diffs) via --attach. Hard 1MB payload limits prevent context window explosion.
  • Agentic Observability (v0.5): Native OpenTelemetry-style trace_id and parent_span_id lineage.
  • SLA Timeouts & Dead-Letter (v0.4): Prevent phantom deadlocks. If an agent ghosts the swarm, SLA timers route the payload to okf/dead-letter.
  • Swarm RBAC & Droid Proofs (v0.3): Cryptographic JWT/UUID tokens ensure only authorized agents can publish to restricted topics.
  • HITL Intercepts (v0.3): Catch dangerous payloads (e.g., DROP TABLE) and place them in PENDING_APPROVAL for human review via the TUI.

Install

pip install -U "okf-agentbus[devex,sdk]"

Quickstart & Examples

The best way to understand AgentBus is to read our copy-pasteable examples.

See the examples/ directory for 7 flawless, isolated Python scripts covering every feature from basic Pub/Sub to Pydantic Schemas and 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"}'

Documentation

For full architectural documentation, see the docs/ directory.

License

MIT — see LICENSE.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

okf_agentbus-0.8.1.tar.gz (50.9 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

okf_agentbus-0.8.1-py3-none-any.whl (36.9 kB view details)

Uploaded Python 3

File details

Details for the file okf_agentbus-0.8.1.tar.gz.

File metadata

  • Download URL: okf_agentbus-0.8.1.tar.gz
  • Upload date:
  • Size: 50.9 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.12.3

File hashes

Hashes for okf_agentbus-0.8.1.tar.gz
Algorithm Hash digest
SHA256 923722cdedb7c1cc0070af770259bb4976b96ca094d1b1db08d15d62243717a3
MD5 59620ea4d7e61c565cea20a7680eed27
BLAKE2b-256 3aad1912c6bbf7ad7c517823119772e2ebf7baff25843be7cfd2f363eadeb263

See more details on using hashes here.

File details

Details for the file okf_agentbus-0.8.1-py3-none-any.whl.

File metadata

  • Download URL: okf_agentbus-0.8.1-py3-none-any.whl
  • Upload date:
  • Size: 36.9 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.12.3

File hashes

Hashes for okf_agentbus-0.8.1-py3-none-any.whl
Algorithm Hash digest
SHA256 2bd3a01ebd7748d0a478baacdb9f19e23e28c1cdd6d58b0197e8fe51d2fc510d
MD5 dd1abe2b15604362a4bfdda0ea1fd09c
BLAKE2b-256 93af80ff7bfb489b54890954585312c0a0b6ccf274231a3c044622c414c86a83

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page