test(mcp): align concurrency probe with client error propagation

This commit is contained in:
Joshua Valluru 2026-09-28 16:18:46 -07:00
parent d9239e94b3
commit 812e58a146

View file

@ -47,7 +47,7 @@ def _make_server(server_id: str, max_concurrent_requests: Optional[int]) -> MCPS
def _patch_client_with_tracker(manager: MCPServerManager, tracker: _ConcurrencyTracker):
async def fake_create_mcp_client(server, **kwargs):
class _ProbeClient:
async def call_tool(self, params, host_progress_callback=None, allow_input_required=False):
async def call_tool(self, params, host_progress_callback=None, allow_input_required=False, raise_on_error: bool = False):
tracker.enter(server.server_id)
try:
await asyncio.sleep(HOLD_SECONDS)