queue_status
Resolve communication delays between AI assistants by checking queue counts and reviewing recent completions for debugging.
Instructions
Return queue counts + recent completions (debugging).
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||
Implementation Reference
- src/teammate_mcp/server.py:157-160 (handler)The actual MCP tool handler for queue_status. Defined as a synchronous function returning a dict, decorated with @mcp.tool(). It delegates to _queue.status() which returns queue counts and recent completions.
@mcp.tool() def queue_status() -> dict: """Return queue counts + recent completions (debugging).""" return _queue.status() - src/teammate_mcp/queue.py:130-147 (helper)The status() method on MessageQueue, which is the backing logic that queue_status calls. It counts JSON files in pending/inflight/done/failed subdirectories and returns the 5 most recent done message IDs.
def status(self) -> dict: def _count(sub: str) -> int: return len(list((self.base / sub).glob("*.json"))) recent_done = sorted( (self.base / "done").glob("*.json"), key=lambda p: p.stat().st_mtime, reverse=True, )[:5] return { "mode": self.mode, "base": str(self.base), "pending": _count("pending"), "inflight": _count("inflight"), "done": _count("done"), "failed": _count("failed"), "recent_done_ids": [p.stem for p in recent_done], } - src/teammate_mcp/server.py:157-157 (registration)The @mcp.tool() decorator registers queue_status as an MCP tool on the FastMCP instance named 'mcp' (line 52). This is the registration mechanism that makes it discoverable.
@mcp.tool() - src/teammate_mcp/queue.py:26-38 (helper)The Message dataclass used by MessageQueue to store individual messages. queue_status aggregates these messages into counts.
@dataclass class Message: id: str from_agent: str to_agent: str question: str created_at: float priority: int = 1 timeout: int = 300 answer: Optional[str] = None completed_at: Optional[float] = None failed_reason: Optional[str] = None