44from mcp import Client , types
55from mcp .client .session import ClientSession
66from mcp .server import Server , ServerRequestContext
7+ from mcp .shared ._context import RequestContext
78from mcp .shared .exceptions import MCPError
89from mcp .shared .memory import create_client_server_memory_streams
910from mcp .shared .message import SessionMessage
@@ -424,6 +425,7 @@ async def test_callback_exception_propagation():
424425 """Verify that exceptions raised in callbacks with __mcp_propagate__ = True
425426 are propagated to the awaiter of send_request, and result in INTERNAL_ERROR to peer.
426427 """
428+
427429 class CustomPropagatedException (Exception ):
428430 __mcp_propagate__ = True
429431
@@ -455,7 +457,7 @@ async def mock_server():
455457 server_error_holder .append (response_msg .message )
456458 ev_server_received_error .set ()
457459
458- async def mock_list_roots (ctx ):
460+ async def mock_list_roots (context : RequestContext [ ClientSession ] ):
459461 raise CustomPropagatedException ("Callback error that should propagate" )
460462
461463 async def make_request (client_session : ClientSession ):
@@ -480,4 +482,3 @@ async def make_request(client_session: ClientSession):
480482
481483 assert len (server_error_holder ) == 1
482484 assert server_error_holder [0 ].error .code == INTERNAL_ERROR
483-
0 commit comments