arcade-mcp/examples/evals/eval_comprehensive_comparison.py
jottakka 98fad93d21
Adding MCP Servers supports to Arcade Evals (#689)
# MCP Server Tool Evaluation Support

## Overview
Add support for evaluating tools from remote MCP servers without
requiring Python callables. Enables direct evaluation of any
MCP-compatible tool server.

## What's New

### Core Features
- **`MCPToolRegistry`**: Evaluate tools from a single MCP server
- **`CompositeMCPRegistry`**: Evaluate tools from multiple MCP servers
simultaneously
- **Automatic loaders**: `load_from_stdio()` and `load_from_http()` to
fetch tools from running servers
- **Automatic namespacing**: Tools prefixed with server name (e.g.,
`server_tool_name`)
- **Smart name resolution**: Use short names if unique, full names if
ambiguous
- **OpenAI strict mode**: Automatic schema conversion prevents parameter
hallucinations

### Usage

**Automatic Loading:**
```python
from arcade_evals import load_from_stdio, MCPToolRegistry

# Load tools automatically from MCP server
tools = load_from_stdio(["npx", "-y", "@modelcontextprotocol/server-github"])
registry = MCPToolRegistry(tools)
```

**Single MCP Server:**
```python
from arcade_evals import MCPToolRegistry, ExpectedToolCall

registry = MCPToolRegistry(mcp_tools)
suite = EvalSuite(catalog=registry)

suite.add_case(
    expected_tool_calls=[
        ExpectedToolCall(tool_name="tool_name", args={...})
    ]
)
```

**Multiple MCP Servers:**
```python
from arcade_evals import CompositeMCPRegistry, load_from_stdio

# Load from multiple servers
github_tools = load_from_stdio(["npx", "-y", "@modelcontextprotocol/server-github"])
slack_tools = load_from_stdio(["npx", "-y", "@modelcontextprotocol/server-slack"])

composite = CompositeMCPRegistry(
    tool_lists={
        "github": github_tools,
        "slack": slack_tools,
    }
)

suite = EvalSuite(catalog=composite)

suite.add_case(
    expected_tool_calls=[
        ExpectedToolCall(tool_name="github_list_issues", args={...})
    ]
)
```

## Implementation

### Files Changed
- **`libs/arcade-evals/arcade_evals/registry.py`** (NEW): Registry
abstractions and implementations
- **`libs/arcade-evals/arcade_evals/loaders.py`** (NEW): Automatic tool
loading from MCP servers
- **`libs/arcade-evals/arcade_evals/eval.py`** (MODIFIED): Enhanced
`ExpectedToolCall` and evaluation logic
- **`libs/arcade-evals/arcade_evals/__init__.py`** (MODIFIED): Exported
new registries and loaders

### Key Technical Details
- Added `BaseToolRegistry` interface for abstraction
- `MCPToolRegistry` handles single server tools
- `CompositeMCPRegistry` manages multiple servers with collision
detection
- `load_from_stdio()` and `load_from_http()` for automatic tool
discovery
- Fixed name normalization bug: MCP tools use underscores (not dots)
- Optimized tool copying: 2.5x faster via shallow copy

## Testing
-  41 tests passing (25 new tests added)
-  `test_eval_mcp_registry.py`: MCPToolRegistry functionality
-  `test_eval_composite_mcp.py`: CompositeMCPRegistry with multiple
servers
-  Verified backward compatibility with Python tools

## Backward Compatibility
 **100% backward compatible** - No breaking changes


## Breaking Changes
**None**


<!-- CURSOR_SUMMARY -->
---

> [!NOTE]
> Adds end-to-end eval UX: examples, a robust CLI runner, and rich
outputs.
> 
> - **New examples**: `eval_arcade_gateway.py`,
`eval_stdio_mcp_server.py`, `eval_http_mcp_server.py`,
`eval_comprehensive_comparison.py` with timeouts, error handling, and
track-based comparisons; detailed `README.md`
> - **CLI runner**: `arcade_cli/evals_runner.py` to execute
evals/capture in parallel with progress, error isolation, failed-only
filtering, context inclusion, and multi-provider/model support
> - **Output formatters**: `arcade_cli/formatters/` (txt, md, html,
json) for evals and capture; comparative and multi-model HTML with tabs
and context rendering
> - **Display refactor**: `display.py` now supports writing multiple
formats, failed-only disclaimers, include-context, and improved console
summaries
> 
> <sup>Written by [Cursor
Bugbot](https://cursor.com/dashboard?tab=bugbot) for commit
ff8acf9c34a6b61462a019a1ee9df081006517d0. This will update automatically
on new commits. Configure
[here](https://cursor.com/dashboard?tab=bugbot).</sup>
<!-- /CURSOR_SUMMARY -->

---------

Co-authored-by: Francisco Liberal <francisco@arcade.dev>
Co-authored-by: Mateo Torres <torresmateo@gmail.com>
2026-01-07 20:26:23 -03:00

229 lines
7.3 KiB
Python

"""Comprehensive comparison across multiple tool sources.
This example demonstrates comparative evaluations across different sources:
- Arcade Gateway (cloud toolkits)
- Local stdio MCP servers
- Dict-based tool definitions (baseline)
Run:
arcade evals examples/evals/eval_comprehensive_comparison.py \\
-p "openai:gpt-4o anthropic:claude-sonnet-4-5-20250929" \\
-k openai:YOUR_KEY -k anthropic:YOUR_KEY \\
-o comparison.html -d
"""
import asyncio
import os
from arcade_evals import (
BinaryCritic,
EvalRubric,
EvalSuite,
ExpectedMCPToolCall,
MCPToolDefinition,
SimilarityCritic,
tool_eval,
)
# =============================================================================
# CONFIGURATION
# =============================================================================
ARCADE_API_KEY = os.environ.get("ARCADE_API_KEY", "YOUR_ARCADE_API_KEY_HERE")
ARCADE_USER_ID = os.environ.get("ARCADE_USER_ID", "YOUR_USER_ID_HERE")
EXAMPLES_DIR = os.path.dirname(os.path.dirname(__file__))
SIMPLE_SERVER_PATH = os.path.join(EXAMPLES_DIR, "mcp_servers", "simple")
SIMPLE_SERVER_COMMAND = [
"uv",
"run",
"--directory",
SIMPLE_SERVER_PATH,
"simple",
]
# Baseline dict tool (for comparison)
DICT_SEARCH: MCPToolDefinition = {
"name": "search",
"description": "Search for information",
"inputSchema": {
"type": "object",
"properties": {
"query": {"type": "string", "description": "Search query"},
},
"required": ["query"],
},
}
default_rubric = EvalRubric(
fail_threshold=0.6,
warn_threshold=0.8,
fail_on_tool_selection=False,
)
# =============================================================================
# EVAL SUITE
# =============================================================================
@tool_eval()
async def eval_comprehensive_comparison() -> EvalSuite:
"""Compare tool performance across multiple sources."""
suite = EvalSuite(
name="Multi-Source Comparative Evaluation",
system_message="You are a helpful assistant with various tools available.",
rubric=default_rubric,
)
loaded_tracks: list[str] = []
# Always add baseline dict tools
suite.add_tool_definitions([DICT_SEARCH], track="dict_baseline")
loaded_tracks.append("dict_baseline")
print("\n Loading tool sources...")
# Load from Arcade Gateway
try:
print(" → Loading Arcade Gateway (Math)...")
await asyncio.wait_for(
suite.add_arcade_gateway(
gateway_slug="Math",
arcade_api_key=ARCADE_API_KEY,
arcade_user_id=ARCADE_USER_ID,
track="arcade_gateway",
),
timeout=10.0,
)
loaded_tracks.append("arcade_gateway")
print(" ✓ Arcade Gateway")
except asyncio.TimeoutError:
print(" ✗ Arcade Gateway - timeout")
except Exception as e:
print(f" ✗ Arcade Gateway - {type(e).__name__}: {e}")
# Load from stdio MCP server
try:
print(" → Loading stdio MCP server (simple)...")
await asyncio.wait_for(
suite.add_mcp_stdio_server(
command=SIMPLE_SERVER_COMMAND,
env={"PYTHONUNBUFFERED": "1"},
track="stdio_simple",
),
timeout=15.0,
)
loaded_tracks.append("stdio_simple")
print(" ✓ Stdio MCP server")
except asyncio.TimeoutError:
print(" ✗ Stdio MCP server - timeout")
except Exception as e:
print(f" ✗ Stdio MCP server - {type(e).__name__}: {e}")
print(f"\n Loaded tracks: {loaded_tracks}\n")
# =========================================================================
# TEST CASE 1: Math operation (Arcade Gateway vs baseline)
# =========================================================================
if "arcade_gateway" in loaded_tracks:
case1 = suite.add_comparative_case(
name="Math addition - Gateway vs Baseline",
user_message="What is 15 plus 27?",
)
case1.for_track(
"arcade_gateway",
expected_tool_calls=[
ExpectedMCPToolCall(
tool_name="Math_Add",
args={"a": 15, "b": 27},
)
],
critics=[
BinaryCritic(critic_field="a", weight=0.5),
BinaryCritic(critic_field="b", weight=0.5),
],
)
case1.for_track(
"dict_baseline",
expected_tool_calls=[
ExpectedMCPToolCall(
tool_name="search",
args={"query": "15 plus 27"},
)
],
critics=[SimilarityCritic(critic_field="query", weight=1.0, similarity_threshold=0.3)],
)
# =========================================================================
# TEST CASE 2: Echo operation (stdio vs baseline)
# =========================================================================
if "stdio_simple" in loaded_tracks:
case2 = suite.add_comparative_case(
name="Echo message - Stdio vs Baseline",
user_message="Echo 'Hello World'",
)
case2.for_track(
"stdio_simple",
expected_tool_calls=[
ExpectedMCPToolCall(
tool_name="echo",
args={"message": "Hello World"},
)
],
critics=[
BinaryCritic(critic_field="message", weight=1.0),
],
)
case2.for_track(
"dict_baseline",
expected_tool_calls=[
ExpectedMCPToolCall(
tool_name="search",
args={"query": "Hello World"},
)
],
critics=[SimilarityCritic(critic_field="query", weight=1.0, similarity_threshold=0.5)],
)
# =========================================================================
# TEST CASE 3: Conversational context
# =========================================================================
if "arcade_gateway" in loaded_tracks:
case3 = suite.add_comparative_case(
name="Math with context",
user_message="Now add them together",
additional_messages=[
{"role": "user", "content": "I have two numbers: 50 and 25"},
{"role": "assistant", "content": "I'll remember those numbers."},
],
)
case3.for_track(
"arcade_gateway",
expected_tool_calls=[
ExpectedMCPToolCall(
tool_name="Math_Add",
args={"a": 50, "b": 25},
)
],
critics=[
BinaryCritic(critic_field="a", weight=0.5),
BinaryCritic(critic_field="b", weight=0.5),
],
)
case3.for_track(
"dict_baseline",
expected_tool_calls=[
ExpectedMCPToolCall(
tool_name="search",
args={"query": "50 plus 25"},
)
],
critics=[SimilarityCritic(critic_field="query", weight=1.0, similarity_threshold=0.3)],
)
return suite