|
1 |
| -import asyncio |
| 1 | +"""Test for issue #552: stdio_client hangs on Windows.""" |
| 2 | + |
2 | 3 | import sys
|
| 4 | +from textwrap import dedent |
3 | 5 |
|
| 6 | +import anyio |
4 | 7 | import pytest
|
5 | 8 |
|
6 | 9 | from mcp import ClientSession, StdioServerParameters
|
7 | 10 | from mcp.client.stdio import stdio_client
|
8 | 11 |
|
9 |
| -# @pytest.mark.skipif(sys.platform != "win32", reason="Windows-specific test") |
10 |
| -@pytest.mark.skipif(sys.version_info < (3, 11), reason="asyncio.timeout in 3.11+") |
11 |
| -@pytest.mark.parametrize( |
12 |
| - "args", |
13 |
| - [ |
14 |
| - ["/C", "echo", '{"jsonrpc": "2.0", "id": 1, "result": null}'], |
15 |
| - ["dfghfgh"], |
16 |
| - ["/C", "echo"], |
17 |
| - ], |
18 |
| -) |
| 12 | + |
| 13 | +@pytest.mark.skipif(sys.platform != "win32", reason="Windows-specific test") |
19 | 14 | @pytest.mark.anyio
|
20 |
| -async def test_windows_process_creation(args): |
| 15 | +async def test_windows_stdio_client_with_session(): |
21 | 16 | """
|
22 |
| - Test that directly tests the process creation function that was fixed in issue #552. |
23 |
| - This simpler test verifies that Windows process creation works without hanging. |
| 17 | + Test the exact scenario from issue #552: Using ClientSession with stdio_client. |
| 18 | +
|
| 19 | + This reproduces the original bug report where stdio_client hangs on Windows 11 |
| 20 | + when used with ClientSession. |
24 | 21 | """
|
25 |
| - # Use a simple command that should complete quickly on Windows |
| 22 | + # Create a minimal MCP server that responds to initialization |
| 23 | + server_script = dedent(""" |
| 24 | + import json |
| 25 | + import sys |
| 26 | +
|
| 27 | + # Read initialization request |
| 28 | + line = sys.stdin.readline() |
| 29 | +
|
| 30 | + # Send initialization response |
| 31 | + response = { |
| 32 | + "jsonrpc": "2.0", |
| 33 | + "id": 1, |
| 34 | + "result": { |
| 35 | + "protocolVersion": "1.0", |
| 36 | + "capabilities": {}, |
| 37 | + "serverInfo": {"name": "test-server", "version": "1.0"} |
| 38 | + } |
| 39 | + } |
| 40 | + print(json.dumps(response)) |
| 41 | + sys.stdout.flush() |
| 42 | +
|
| 43 | + # Exit after a short delay |
| 44 | + import time |
| 45 | + time.sleep(0.1) |
| 46 | + sys.exit(0) |
| 47 | + """).strip() |
| 48 | + |
26 | 49 | params = StdioServerParameters(
|
27 |
| - command="cmd", |
28 |
| - # Echo a valid JSON-RPC response message that will be parsed correctly |
29 |
| - args=args, |
| 50 | + command=sys.executable, |
| 51 | + args=["-c", server_script], |
30 | 52 | )
|
31 | 53 |
|
32 |
| - # Directly test the fixed function that was causing the hanging issue |
33 |
| - try: |
34 |
| - # Set a timeout to prevent hanging |
35 |
| - async with asyncio.timeout(5): |
36 |
| - # Test the actual process creation function that was fixed |
| 54 | + # This is the exact pattern from the bug report |
| 55 | + with anyio.fail_after(10): |
| 56 | + try: |
37 | 57 | async with stdio_client(params) as (read, write):
|
38 |
| - print("inside client") |
39 |
| - async with ClientSession(read, write) as c: |
40 |
| - print("inside ClientSession") |
41 |
| - await c.initialize() |
42 |
| - |
43 |
| - except asyncio.TimeoutError: |
44 |
| - pytest.xfail("Process creation timed out, indicating a hang issue") |
45 |
| - except ProcessLookupError: |
46 |
| - pytest.xfail("Process creation failed with ProcessLookupError") |
47 |
| - except Exception as e: |
48 |
| - assert "ExceptionGroup" in repr(e), f"Unexpected error: {e}" |
49 |
| - assert "ProcessLookupError" in repr(e), f"Unexpected error: {e}" |
50 |
| - pytest.xfail(f"Expected error: {e}") |
| 58 | + async with ClientSession(read, write) as session: |
| 59 | + await session.initialize() |
| 60 | + # Should exit ClientSession without hanging |
| 61 | + # Should exit stdio_client without hanging |
| 62 | + except Exception: |
| 63 | + # Connection errors are expected when process exits |
| 64 | + pass |
0 commit comments