lint

Author: gyang-xai

src/mcp/client/streamable_http.py

@@ -334,7 +334,7 @@ async def _handle_resumption_request(self, ctx: RequestContext) -> None:
     async def _send_error_response(self, ctx: RequestContext, error: Exception) -> None:
         """Send an error response to the client."""
         error_data = ErrorData(code=32000, message=str(error))
-        if isinstance(ctx.session_message.message.root, JSONRPCRequest):
+        if isinstance(ctx.session_message.message.root, JSONRPCRequest):  # pragma: no branch
             jsonrpc_error = JSONRPCError(jsonrpc="2.0", id=ctx.session_message.message.root.id, error=error_data)
             session_message = SessionMessage(message=JSONRPCMessage(jsonrpc_error))
             await ctx.read_stream_writer.send(session_message)

tests/shared/test_streamable_http.py

@@ -2411,7 +2411,7 @@ async def test_sse_stream_ends_without_completing_no_event_id() -> None:
     mock_response = MagicMock()
 
     async def mock_aclose() -> None:
-        pass
+        pass  # pragma: no cover
 
     mock_response.aclose = mock_aclose
 
@@ -2478,7 +2478,7 @@ async def __aenter__(self) -> None:
             raise httpx.HTTPStatusError("Server error", request=MagicMock(), response=MagicMock(status_code=500))
 
         async def __aexit__(self, exc_type: Any, exc_val: Any, exc_tb: Any) -> None:
-            pass
+            pass  # pragma: no cover
 
     mock_client.stream = MagicMock(return_value=FailingStream())
 
@@ -2538,7 +2538,7 @@ async def __aenter__(self) -> None:
             raise httpx.HTTPStatusError("Server error", request=MagicMock(), response=MagicMock(status_code=500))
 
         async def __aexit__(self, exc_type: Any, exc_val: Any, exc_tb: Any) -> None:
-            pass
+            pass  # pragma: no cover
 
     mock_client.stream = MagicMock(return_value=FailingStream())