[feat] Sub-Agent Status & Cancel Tools Added check_sub_agent_status and cancel_sub_agent_tasks as new autonomous planning tools with full schema definitions and registry-backed handler implementations, wired into Agent's

  tool dispatch map [feat] Async Sub-Agent Registry Refactor Replaced raw asyncio dispatching in assign_task_tool with SubagentRegistry-based spawning for consistent task tracking, retries, and cancellation; added
  _find_registry and _resolve_sub_agents_by_name helpers [feat] Sub-Agent Print Visibility Enabled print_on=True for sub-agents created via create_sub_agent_tool to surface their output during execution [improvement]
  LiteLLM Empty System Prompt Fix Fixed Anthropic API rejections by stripping whitespace-only system prompt blocks and normalizing orchestrator-style System:/Human: prompts before message construction [improvement] PDF
  Utility Removal Removed pdf_to_text as a core utility from utils/__init__.py and data_to_text.py, inlining a local implementation directly in the mem0 example script [improvement] Agent Class Cleanup Removed duplicated
  async sub-agent methods from Agent class body now superseded by registry integration [improvement] top_p Default Fix Removed hardcoded top_p=None from auto_chat_agent and set Agent.top_p default to None to avoid
  unintended sampling parameter injection [improvement] Model & Version Update Bumped swarms to 9.0.3 and updated default model references from gpt-4.1/claude-sonnet-4-5 to gpt-5.4/gpt-5.1 across example files and CLI

Author: kyegomez

example.py

@@ -5,7 +5,7 @@
     agent_name="Quantitative-Trading-Agent",
     agent_description="Advanced quantitative trading and algorithmic analysis agent",
     system_prompt="You are a helpful assistant that can answer questions and help with tasks and your name is Quantitative-Trading-Agent",
-    model_name="gpt-4.1",
+    model_name="gpt-5.4",
     dynamic_temperature_enabled=True,
     max_loops=2,
     dynamic_context_window=True,

examples/guides/mem0/mem0_and_swarms.py

@@ -3,7 +3,6 @@
 
 from mem0 import MemoryClient
 from swarms import Agent
-from swarms.utils.pdf_to_text import pdf_to_text
 from swarms.utils.data_to_text import csv_to_text
 from dotenv import load_dotenv
 
@@ -45,6 +44,32 @@ def chunk_text(
     return chunks
 
 
+def pdf_to_text(pdf_path: str) -> str:
+    """
+    Extract text from a PDF file for this example script.
+
+    Args:
+        pdf_path (str): Path to the PDF file.
+
+    Returns:
+        str: Extracted text from all PDF pages.
+    """
+    try:
+        import pypdf
+    except ImportError as exc:
+        raise ImportError(
+            "pypdf is required for PDF support in this example. "
+            "Install it with `pip install pypdf`."
+        ) from exc
+
+    with open(pdf_path, "rb") as file:
+        reader = pypdf.PdfReader(file)
+        pages = []
+        for page in reader.pages:
+            pages.append(page.extract_text() or "")
+    return "\n".join(pages)
+
+
 def read_pdf(pdf_path: str) -> str:
     """
     Read and extract text content from a PDF file.

pyproject.toml

@@ -5,7 +5,7 @@ build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
 name = "swarms"
-version = "9.0.2"
+version = "9.0.3"
 description = "Swarms - TGSC"
 license = "MIT"
 authors = ["Kye Gomez <[email protected]>"]

sub_agent_test.py

@@ -0,0 +1,18 @@
+from swarms import Agent
+
+# Initialize the agent
+agent = Agent(
+    agent_name="Quantitative-Trading-Agent",
+    agent_description="Advanced quantitative trading and algorithmic analysis agent",
+    system_prompt="You are a helpful assistant that can answer questions and help with tasks and your name is Quantitative-Trading-Agent",
+    model_name="gpt-5.4",
+    max_loops="auto",
+    dynamic_context_window=True,
+    reasoning_effort=None,
+)
+
+out = agent.run(
+    "Create 2 simple sub agents that just say hello and nothing else"
+)
+
+print(out)

swarms/agents/auto_chat_agent.py

@@ -29,7 +29,6 @@ def auto_chat_agent(
         dynamic_temperature_enabled=True,
         max_loops="auto",
         temperature=temperature,
-        top_p=None,
     )
 
     current_task = task

swarms/cli/main.py

@@ -837,7 +837,7 @@ def __call__(
         print()
         print("Examples:")
         print(f"  {prog_name} chat")
-        print(f"  {prog_name} chat --model-name claude-sonnet-4-5")
+        print(f"  {prog_name} chat --model-name gpt-5.4")
         print(f"  {prog_name} chat --model-name claude-opus-4-6")
         print(f"  {prog_name} chat --model-name gpt-4o")
         print(
@@ -950,7 +950,7 @@ def setup_argument_parser() -> argparse.ArgumentParser:
         "--model-name",
         type=str,
         default=None,
-        help="Model name to use (e.g. claude-sonnet-4-5, gpt-4o, claude-opus-4-6). Defaults to claude-sonnet-4-5 for chat, gpt-4 for agent.",
+        help="Model name to use (e.g. gpt-5.4, gpt-4o, claude-opus-4-6). Defaults to gpt-5.4 for chat, gpt-4 for agent.",
     )
     parser.add_argument(
         "--task",
@@ -1526,16 +1526,14 @@ def handle_chat(args: argparse.Namespace) -> Optional[Agent]:
             or "A Swarms agent that can chat with the user."
         )
         system_prompt = getattr(args, "system_prompt", None)
-        model_name = (
-            getattr(args, "model_name", None) or "claude-sonnet-4-5"
-        )
+        model_name = getattr(args, "model_name", None) or "gpt-5.1"
         task = getattr(args, "task", None)
 
         console.print(
             f"\n[bold white]{name}[/bold white]  [dim white]({model_name})[/dim white]"
         )
         console.print(
-            "[dim white]  Switch model: [/dim white][white]swarms chat --model-name claude-sonnet-4-5[/white]"
+            "[dim white]  Switch model: [/dim white][white]swarms chat --model-name gpt-5.4[/white]"
             "[dim white]  ·  other options: claude-opus-4-6, gpt-4o, gemini/gemini-2.0-flash[/dim white]\n"
         )
 

swarms/structs/agent.py

@@ -67,6 +67,8 @@
     MAX_SUBTASK_ITERATIONS,
     MAX_SUBTASK_LOOPS,
     assign_task_tool,
+    check_sub_agent_status_tool,
+    cancel_sub_agent_tasks_tool,
     create_file_tool,
     create_sub_agent_tool,
     delete_file_tool,
@@ -82,6 +84,7 @@
     update_file_tool,
 )
 from swarms.structs.conversation import Conversation
+from swarms.structs.dynamic_skills_loader import DynamicSkillsLoader
 from swarms.structs.ma_utils import set_random_models_for_agents
 from swarms.structs.safe_loading import (
     SafeLoaderUtils,
@@ -126,7 +129,6 @@
     add_prompt_to_marketplace,
 )
 from swarms.utils.workspace_utils import get_workspace_dir
-from swarms.structs.dynamic_skills_loader import DynamicSkillsLoader
 
 
 def stop_when_repeats(response: str) -> bool:
@@ -426,7 +428,7 @@ def __init__(
         random_models_on: bool = False,
         mcp_config: Optional[MCPConnection] = None,
         mcp_configs: Optional[MultipleMCPConnections] = None,
-        top_p: Optional[float] = 0.90,
+        top_p: Optional[float] = None,
         llm_base_url: Optional[str] = None,
         llm_api_key: Optional[str] = None,
         tool_call_summary: bool = True,
@@ -2324,6 +2326,12 @@ def _run_autonomous_loop(
                 "assign_task": lambda **kwargs: assign_task_tool(
                     self, **kwargs
                 ),
+                "check_sub_agent_status": lambda **kwargs: check_sub_agent_status_tool(
+                    self, **kwargs
+                ),
+                "cancel_sub_agent_tasks": lambda **kwargs: cancel_sub_agent_tasks_tool(
+                    self, **kwargs
+                ),
             }
 
             # Filter tool handlers if selected_tools is not "all"
@@ -3119,83 +3127,6 @@ async def arun(
                 error
             )  # Ensure this is also async if needed
 
-    # ── Async Subagent Methods ──────────────────────────────
-
-    def _get_registry(self):
-        """Lazy-init and return the SubagentRegistry."""
-        if self._subagent_registry is None:
-            from swarms.structs.async_subagent import (
-                SubagentRegistry,
-            )
-
-            self._subagent_registry = SubagentRegistry(
-                max_depth=self.max_subagent_depth
-            )
-        return self._subagent_registry
-
-    def run_async(self, task: str):
-        """
-        Run this agent's task in the background, returning a Future.
-        """
-        registry = self._get_registry()
-        return registry._executor.submit(self.run, task)
-
-    def spawn_async(
-        self,
-        agent,
-        task: str,
-        max_retries: int = 0,
-        retry_on=None,
-        fail_fast: bool = True,
-    ) -> str:
-        """
-        Spawn a subagent to run a task in the background.
-
-        Returns task_id for tracking via get_subagent_results() / gather_results().
-        """
-        registry = self._get_registry()
-        return registry.spawn(
-            agent=agent,
-            task=task,
-            parent_id=self.id,
-            depth=0,
-            max_retries=max_retries,
-            retry_on=retry_on,
-            fail_fast=fail_fast,
-        )
-
-    def run_in_background(self, task: str) -> str:
-        """
-        Convenience: spawn self as a background task, return task_id.
-        """
-        registry = self._get_registry()
-        return registry.spawn(
-            agent=self,
-            task=task,
-            parent_id=None,
-            depth=0,
-        )
-
-    def gather_results(
-        self,
-        strategy: str = "wait_all",
-        timeout: float = None,
-    ):
-        """Wait for spawned subagents and return their results."""
-        return self._get_registry().gather(
-            strategy=strategy, timeout=timeout
-        )
-
-    def get_subagent_results(self):
-        """Collect results from all completed subagent tasks."""
-        return self._get_registry().get_results()
-
-    def cancel_subagent(self, task_id: str) -> bool:
-        """Cancel a spawned subagent task."""
-        return self._get_registry().cancel(task_id)
-
-    # ── End Async Subagent Methods ──────────────────────────
-
     def __call__(
         self,
         task: Optional[str] = None,