|
| 1 | +from __future__ import annotations |
| 2 | + |
| 3 | +import importlib |
| 4 | +import importlib.abc |
| 5 | +import sys |
| 6 | +from types import ModuleType |
| 7 | + |
| 8 | +import pytest |
| 9 | + |
| 10 | +_SERVER_EXPORTS = ( |
| 11 | + "LocalMCPApprovalCallable", |
| 12 | + "MCPServer", |
| 13 | + "MCPServerSse", |
| 14 | + "MCPServerSseParams", |
| 15 | + "MCPServerStdio", |
| 16 | + "MCPServerStdioParams", |
| 17 | + "MCPServerStreamableHttp", |
| 18 | + "MCPServerStreamableHttpParams", |
| 19 | +) |
| 20 | + |
| 21 | + |
| 22 | +class _BrokenMCPServerImportFinder(importlib.abc.MetaPathFinder): |
| 23 | + def find_spec( |
| 24 | + self, |
| 25 | + fullname: str, |
| 26 | + path: object | None, |
| 27 | + target: ModuleType | None = None, |
| 28 | + ) -> None: |
| 29 | + if fullname == "agents.mcp.server": |
| 30 | + raise ImportError("simulated dependency import failure") |
| 31 | + return None |
| 32 | + |
| 33 | + |
| 34 | +def _clear_mcp_server_imports( |
| 35 | + monkeypatch: pytest.MonkeyPatch, |
| 36 | + mcp_module: ModuleType, |
| 37 | +) -> None: |
| 38 | + monkeypatch.delitem(sys.modules, "agents.mcp.server", raising=False) |
| 39 | + monkeypatch.delitem(mcp_module.__dict__, "server", raising=False) |
| 40 | + for name in _SERVER_EXPORTS: |
| 41 | + monkeypatch.delitem(mcp_module.__dict__, name, raising=False) |
| 42 | + |
| 43 | + |
| 44 | +def test_mcp_package_import_does_not_eagerly_import_server( |
| 45 | + monkeypatch: pytest.MonkeyPatch, |
| 46 | +) -> None: |
| 47 | + import agents.mcp as mcp_module |
| 48 | + |
| 49 | + _clear_mcp_server_imports(monkeypatch, mcp_module) |
| 50 | + finder = _BrokenMCPServerImportFinder() |
| 51 | + monkeypatch.setattr(sys, "meta_path", [finder, *sys.meta_path]) |
| 52 | + |
| 53 | + reloaded_mcp = importlib.reload(mcp_module) |
| 54 | + |
| 55 | + assert reloaded_mcp.MCPUtil is not None |
| 56 | + |
| 57 | + |
| 58 | +def test_mcp_server_reexport_preserves_underlying_import_error( |
| 59 | + monkeypatch: pytest.MonkeyPatch, |
| 60 | +) -> None: |
| 61 | + import agents.mcp as mcp_module |
| 62 | + |
| 63 | + _clear_mcp_server_imports(monkeypatch, mcp_module) |
| 64 | + finder = _BrokenMCPServerImportFinder() |
| 65 | + monkeypatch.setattr(sys, "meta_path", [finder, *sys.meta_path]) |
| 66 | + namespace: dict[str, object] = {} |
| 67 | + |
| 68 | + with pytest.raises(ImportError) as exc_info: |
| 69 | + exec("from agents.mcp import MCPServerStreamableHttp", namespace) |
| 70 | + |
| 71 | + assert "Failed to import MCPServerStreamableHttp from agents.mcp" in str(exc_info.value) |
| 72 | + assert isinstance(exc_info.value.__cause__, ImportError) |
| 73 | + assert "simulated dependency import failure" in str(exc_info.value.__cause__) |
0 commit comments