What problem does it solve?
Orchestrate complex, event-driven agent workflows by building custom harnesses that coordinate multiple agents, intercept events in real-time, and manage per-harness state and history.
Core Features & Use Cases
- Harness ABC and HarnessContext for orchestrating custom flows, with execute() as the entry point.
- Middleware support (TimeoutMiddleware, CostTrackingMiddleware, and custom middlewares) to control timing and costs.
- Parallel sub-agent execution via SubAgentTask, SubAgentResult, and SubAgentStatus for fan-out patterns.
- Checkpointing and resume using MemoryStore and CheckpointAdapter to persist progress across restarts.
- HarnessNode integration to compose harnesses within Swarms and power modular workflows.
- Run/stream interfaces (run and run.stream) for non-streaming and streaming consumption of harness output.
Quick Start
Create a custom harness by extending Harness and implementing execute(), then run it with run(harness, input) to begin orchestration.