Skip to content

Commit f86b9ce

Browse files
committed
Merge remote-tracking branch 'fork/feat/graphworkflow-conditional-edges' into feat/graphworkflow-retry-policy
# Conflicts: # swarms/structs/graph_workflow.py
2 parents aaad23c + b223123 commit f86b9ce

163 files changed

Lines changed: 5673 additions & 19161 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

CLAUDE.md

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -507,10 +507,8 @@ result = router.run("Write a blog post about transformer architectures.")
507507
| `"HeavySwarm"` | Intensive multi-loop deep analysis |
508508
| `"RoundRobin"` | Round-robin task distribution |
509509
| `"PlannerWorkerSwarm"` | Planner + worker delegation |
510-
| `"BatchedGridWorkflow"` | Grid-based batch execution |
511510
| `"LLMCouncil"` | LLM-based council decisions |
512511
| `"AutoSwarmBuilder"` | Auto-configures everything |
513-
| `"auto"` | Router selects swarm_type automatically |
514512

515513
---
516514

@@ -938,7 +936,7 @@ agent = Agent(
938936
| High-stakes ruling with deliberation | `CouncilAsAJudge` |
939937
| Structured adversarial debate | `DebateWithJudge` |
940938
| Deep research, many loops | `HeavySwarm` |
941-
| Don't know yet / rapid prototyping | `AutoSwarmBuilder` or `SwarmRouter(swarm_type="auto")` |
939+
| Don't know yet / rapid prototyping | `AutoSwarmBuilder` |
942940
| Need to switch architectures easily | `SwarmRouter` |
943941

944942
---
@@ -1086,8 +1084,6 @@ from swarms import Agent
10861084

10871085
**Don't instantiate heavyweight structures inside tight loops** — create agents and workflows once, reuse them across calls.
10881086

1089-
**Don't pass `tools=[]` (empty list)** — pass `tools=None` instead. An empty list can confuse schema generation.
1090-
10911087
**Don't use `streaming_on=True` and `streaming_callback` together on the same agent**`streaming_on` streams to stdout; `streaming_callback` streams to your function. Pick one.
10921088

10931089
**Don't set `context_compression=False` on very long autonomous sessions** — without compression the agent will eventually hit the context limit and raise an error.

README.md

Lines changed: 0 additions & 64 deletions
Original file line numberDiff line numberDiff line change
@@ -729,69 +729,6 @@ Perfect for implementing complex multi-agent workflows, collaborative problem-so
729729

730730
---
731731

732-
### Agent Orchestration Protocol (AOP)
733-
734-
The **Agent Orchestration Protocol (AOP)** is a powerful framework for deploying and managing agents as distributed services. AOP enables agents to be discovered, managed, and executed through a standardized protocol, making it perfect for building scalable multi-agent systems. [Learn more about AOP](https://docs.swarms.world/api/aop)
735-
736-
```python
737-
from swarms import Agent, AOP
738-
739-
# Create specialized agents
740-
research_agent = Agent(
741-
agent_name="Research-Agent",
742-
agent_description="Expert in research and data collection",
743-
model_name="anthropic/claude-sonnet-4-5",
744-
max_loops=1,
745-
tags=["research", "data-collection", "analysis"],
746-
capabilities=["web-search", "data-gathering", "report-generation"],
747-
role="researcher"
748-
)
749-
750-
analysis_agent = Agent(
751-
agent_name="Analysis-Agent",
752-
agent_description="Expert in data analysis and insights",
753-
model_name="anthropic/claude-sonnet-4-5",
754-
max_loops=1,
755-
tags=["analysis", "data-processing", "insights"],
756-
capabilities=["statistical-analysis", "pattern-recognition", "visualization"],
757-
role="analyst"
758-
)
759-
760-
# Create AOP server
761-
deployer = AOP(
762-
server_name="ResearchCluster",
763-
port=8000,
764-
verbose=True
765-
)
766-
767-
# Add agents to the server
768-
deployer.add_agent(
769-
agent=research_agent,
770-
tool_name="research_tool",
771-
tool_description="Research and data collection tool",
772-
timeout=30,
773-
max_retries=3
774-
)
775-
776-
deployer.add_agent(
777-
agent=analysis_agent,
778-
tool_name="analysis_tool",
779-
tool_description="Data analysis and insights tool",
780-
timeout=30,
781-
max_retries=3
782-
)
783-
784-
# List all registered agents
785-
print("Registered agents:", deployer.list_agents())
786-
787-
# Start the AOP server
788-
deployer.run()
789-
```
790-
791-
Perfect for deploying large scale multi-agent systems. [Read the complete AOP documentation](https://docs.swarms.world/api/aop)
792-
793-
---
794-
795732
## Documentation
796733

797734
The full documentation lives at **[docs.swarms.world](https://docs.swarms.world)**. Below are the resources most useful when building with Swarms — both for humans and for AI coding assistants.
@@ -837,7 +774,6 @@ Swarms seamlessly integrates with industry-standard protocols and open specifica
837774
|----------|-------------|---------------|
838775
| **[MCP (Model Context Protocol)](https://docs.swarms.world/integrations/mcp)** | Standardized protocol for AI agents to interact with external tools and services through MCP servers. Enables dynamic tool discovery and execution. | [MCP Integration Guide](https://docs.swarms.world/integrations/mcp) |
839776
| **[X402](https://docs.swarms.world/examples/integrations/x402-payment)** | Cryptocurrency payment protocol for API endpoints. Enables monetization of agents with pay-per-use models. | [X402 Quickstart](https://docs.swarms.world/examples/integrations/x402-payment) |
840-
| **[AOP (Agent Orchestration Protocol)](https://docs.swarms.world/examples/multi-agent/aop-medical)** | Framework for deploying and managing agents as distributed services. Enables agent discovery, management, and execution through standardized protocols. | [AOP Reference](https://docs.swarms.world/api/aop) |
841777
| **[Swarms Marketplace](https://swarms.world)** | Platform for discovering and sharing production-ready prompts, agents, and tools. Enables automatic prompt loading from the marketplace and publishing your own prompts directly from code. | [Marketplace Tutorial](https://docs.swarms.world/integrations/marketplace) |
842778
| **[Open Responses](https://www.openresponses.org/)** | Open-source specification and ecosystem for multi-provider, interoperable LLM interfaces based on the OpenAI Responses API. Provides a unified schema and tooling for calling language models, streaming results, and composing agentic workflows—independent of provider. | [Open Responses Website](https://www.openresponses.org/) |
843779
| **[Agent Skills](https://docs.swarms.world/agents/agent-skills)** | Lightweight, markdown-based format for defining modular, reusable agent capabilities introduced by Anthropic. Enables specialization of agents without modifying code by loading skill definitions from simple SKILL.md files. | [Agent Skills Documentation](https://docs.swarms.world/agents/agent-skills) |

examples/README.md

Lines changed: 2 additions & 36 deletions
Original file line numberDiff line numberDiff line change
@@ -151,35 +151,6 @@ This directory contains comprehensive examples demonstrating various capabilitie
151151
| [05_auth_and_config.py](mcp/client/05_auth_and_config.py) | API keys, bearer tokens, headers, env secrets, OAuth |
152152
| [06_remote_agents.py](mcp/client/06_remote_agents.py) | Spawn and run agents on a remote MCP server |
153153

154-
#### Agents over Protocol (AOP)
155-
156-
| Example | Description |
157-
|---------|-------------|
158-
| [aop_examples/](aop_examples/) | Agents over Protocol (AOP) examples demonstrating MCP server setup, agent discovery, client interactions, queue-based task submission, medical AOP implementations, and utility functions |
159-
| [README.md](aop_examples/README.md) | AOP examples documentation |
160-
| [server.py](aop_examples/server.py) | AOP server implementation |
161-
| [client/](aop_examples/client/) | AOP client examples and agent discovery including cluster, queue, raw client, and task examples |
162-
| [aop_cluster_example.py](aop_examples/client/aop_cluster_example.py) | AOP cluster example |
163-
| [aop_queue_example.py](aop_examples/client/aop_queue_example.py) | AOP queue-based task submission |
164-
| [aop_raw_client_code.py](aop_examples/client/aop_raw_client_code.py) | Raw AOP client implementation |
165-
| [aop_raw_task_example.py](aop_examples/client/aop_raw_task_example.py) | Raw AOP task example |
166-
| [example_new_agent_tools.py](aop_examples/client/example_new_agent_tools.py) | New agent tools example |
167-
| [get_all_agents.py](aop_examples/client/get_all_agents.py) | Get all available agents |
168-
| [list_agents_and_call_them.py](aop_examples/client/list_agents_and_call_them.py) | List and call agents example |
169-
| [discovery/](aop_examples/discovery/) | Agent discovery examples including communication and discovery testing |
170-
| [example_agent_communication.py](aop_examples/discovery/example_agent_communication.py) | Agent communication example |
171-
| [simple_discovery_example.py](aop_examples/discovery/simple_discovery_example.py) | Simple discovery example |
172-
| [example_aop_discovery.py](aop_examples/discovery/example_aop_discovery.py) | AOP discovery example |
173-
| [medical_aop/](aop_examples/medical_aop/) | Medical AOP implementations |
174-
| [server.py](aop_examples/medical_aop/server.py) | Medical AOP server |
175-
| [client.py](aop_examples/medical_aop/client.py) | Medical AOP client |
176-
| [utils/](aop_examples/utils/) | AOP utility functions |
177-
| [network_management_example.py](aop_examples/utils/network_management_example.py) | Network management example |
178-
| [comprehensive_aop_example.py](aop_examples/utils/comprehensive_aop_example.py) | Comprehensive AOP example |
179-
| [persistence_management_example.py](aop_examples/utils/persistence_management_example.py) | Persistence management example |
180-
| [network_error_example.py](aop_examples/utils/network_error_example.py) | Network error handling example |
181-
| [persistence_example.py](aop_examples/utils/persistence_example.py) | Persistence example |
182-
183154
### Advanced Capabilities
184155

185156
| Example | Description |
@@ -225,7 +196,7 @@ This directory contains comprehensive examples demonstrating various capabilitie
225196
| [README.md](guides/README.md) | Guides documentation |
226197
| [hiearchical_marketing_team.py](guides/hiearchical_marketing_team.py) | Hierarchical marketing team example |
227198
| [840_update/](guides/840_update/) | Update examples from version 8.4.0 including agent rearrange, auto swarm builder, and fallback examples |
228-
| [850_workshop/](guides/850_workshop/) | Workshop examples from version 8.5.0 including AOP, MOA, peer review, and concurrent examples |
199+
| [850_workshop/](guides/850_workshop/) | Workshop examples from version 8.5.0 including MOA, peer review, and concurrent examples |
229200
| [880_update_changelog_examples/](guides/880_update_changelog_examples/) | Changelog examples showcasing new features including marketplace integration, multi-agent structures, workflow orchestration, voice agents, evaluation & debate, routing, and autosaving |
230201
| [changelog_890/](guides/changelog_890/) | Changelog examples from January 2026 release including dynamic skills loader, autonomous agent loop, agent handoffs, API key validation, max loops parameter, multi-tool agent tutorial, hierarchical voice agent, and agent rearrange patterns |
231202
| [mem0/](guides/mem0/) | Mem0 integration examples for memory management with Swarms |
@@ -265,7 +236,7 @@ This directory contains comprehensive examples demonstrating various capabilitie
265236
| [fetch_prompt.py](utils/fetch_prompt.py) | Prompt fetching utilities |
266237
| [litellm_connect_issue.py](utils/litellm_connect_issue.py) | LiteLLM connection issue examples |
267238
| [litellm_network_error_handling.py](utils/litellm_network_error_handling.py) | LiteLLM network error handling |
268-
| [misc/](utils/misc/) | Miscellaneous utility functions including AOP, conversation, CSV agents, and visualization |
239+
| [misc/](utils/misc/) | Miscellaneous utility functions including conversation, CSV agents, and visualization |
269240
| [agent_map_test.py](utils/misc/agent_map_test.py) | Agent map test |
270241
| [conversation_simple.py](utils/misc/conversation_simple.py) | Simple conversation example |
271242
| [conversation_test_truncate.py](utils/misc/conversation_test_truncate.py) | Conversation truncate test |
@@ -275,8 +246,6 @@ This directory contains comprehensive examples demonstrating various capabilitie
275246
| [swarm_matcher_example.py](utils/misc/swarm_matcher_example.py) | Swarm matcher example |
276247
| [test_load_conversation.py](utils/misc/test_load_conversation.py) | Load conversation test |
277248
| [visualizer_test.py](utils/misc/visualizer_test.py) | Visualizer test |
278-
| [aop/](utils/misc/aop/) | AOP utility examples |
279-
| [client.py](utils/misc/aop/client.py) | AOP client utility |
280249
| [telemetry/](utils/telemetry/) | Telemetry and monitoring utilities |
281250

282251
### User Interface
@@ -317,7 +286,6 @@ This directory contains comprehensive examples demonstrating various capabilitie
317286
| Want to use the CLI? | Check out [cli/](cli/) for all CLI command examples |
318287
| Want multi-agent workflows? | Check out [multi_agent/duo_agent.py](multi_agent/duo_agent.py) |
319288
| Need tool integration? | Explore [tools/agent_as_tools.py](tools/agent_as_tools.py) |
320-
| Interested in AOP? | Try [aop_examples/client/example_new_agent_tools.py](aop_examples/client/example_new_agent_tools.py) for agent discovery |
321289
| Want to see social algorithms? | Check out [multi_agent/social_algorithms_examples/](multi_agent/social_algorithms_examples/) |
322290
| Looking for guides? | Visit [guides/](guides/) for comprehensive tutorials |
323291
| Need RAG? | Try [single_agent/rag/](single_agent/capabilities/rag/) for RAG examples |
@@ -476,11 +444,9 @@ This directory contains comprehensive examples demonstrating various capabilitie
476444
| **Multi-Agent Architecture** | Agents as Tools | Using agents as tools in workflows | [Agents as Tools](https://docs.swarms.world/architectures/overview) |
477445
| **Multi-Agent Architecture** | Aggregate Responses | Combining multiple agent outputs | [Aggregate Examples](https://docs.swarms.world/architectures/mixture-of-agents) |
478446
| **Multi-Agent Architecture** | Interactive GroupChat | Real-time agent interactions | [Interactive GroupChat](https://docs.swarms.world/examples/group-chat-example) |
479-
| **Deployment Solutions** | Agent Orchestration Protocol (AOP) | Deploy agents as distributed services with discovery and management | [AOP Reference](https://docs.swarms.world/api/aop) |
480447
| **Applications** | Advanced Research System | Multi-agent research system inspired by Anthropic's research methodology | [AdvancedResearch](https://github.com/The-Swarm-Corporation/AdvancedResearch) |
481448
| **Applications** | Hospital Simulation | Healthcare simulation system using multi-agent architecture | [HospitalSim](https://github.com/The-Swarm-Corporation/HospitalSim) |
482449
| **Applications** | Browser Agents | Web automation with agents | [Browser Agents](https://docs.swarms.world/examples/integrations/browser-use) |
483-
| **Applications** | Medical Analysis | Healthcare applications | [Medical Examples](https://docs.swarms.world/examples/multi-agent/aop-medical) |
484450
| **Applications** | Finance Analysis | Financial applications | [Finance Examples](https://docs.swarms.world/examples/use-cases/financial-analysis) |
485451
| **Cookbook & Templates** | Examples Overview | Complete examples directory | [Examples Index](https://docs.swarms.world/examples/) |
486452
| **Cookbook & Templates** | Cookbook Index | Curated example collection | [Cookbook](https://docs.swarms.world/examples/overviews/cookbook) |

examples/changelogs/v14-zena/08_computer_use_tools.py

Lines changed: 0 additions & 37 deletions
This file was deleted.

examples/changelogs/v14-zena/README.md

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ A few examples reference other providers (`claude-sonnet-4-6` in the hierarchica
2424
| [05_auction_swarm.py](05_auction_swarm.py) | AuctionSwarm | Agents bidding on a task; default and custom scoring |
2525
| [06_groupchat_turn_based.py](06_groupchat_turn_based.py) | Turn-Based GroupChat | Single-speaker bidding with a recency penalty |
2626
| [07_hierarchical_swarm_recovery.py](07_hierarchical_swarm_recovery.py) | HierarchicalSwarm | Worker retry, task reassignment, planning, judge, director overrides |
27-
| [08_computer_use_tools.py](08_computer_use_tools.py) | Computer-Use Tools | Full toolset, and a read-only subset |
2827
| [09_class_to_pydantic.py](09_class_to_pydantic.py) | Pydantic Schemas | Schema from a constructor, and the round-trip back to an `Agent` |
2928
| [10_concurrent_workflow_on_error.py](10_concurrent_workflow_on_error.py) | ConcurrentWorkflow | `on_error` failure policy |
3029
| [11_graph_workflow.py](11_graph_workflow.py) | Performance | Fan-out/fan-in DAG on native rustworkx |

examples/guides/840_update/server.py

Lines changed: 0 additions & 106 deletions
This file was deleted.

0 commit comments

Comments
 (0)