fix: address review feedback on pragma placement

- Move pragma to except line in streamable_http.py per Kludex suggestion
- Remove unnecessary lax no cover from test_streamable_http.py assertions
  (these lines are consistently covered across all CI configurations)

Author: maxisbey

src/mcp/client/streamable_http.py

@@ -200,9 +200,9 @@ async def handle_get_stream(self, client: httpx.AsyncClient, read_stream_writer:
                     # Stream ended normally (server closed) - reset attempt counter
                     attempt = 0
 
-            except Exception as exc:
-                logger.debug(f"GET stream error: {exc}")  # pragma: lax no cover
-                attempt += 1  # pragma: lax no cover
+            except Exception as exc:  # pragma: no cover
+                logger.debug(f"GET stream error: {exc}")
+                attempt += 1
 
             if attempt >= MAX_RECONNECTION_ATTEMPTS:  # pragma: no cover
                 logger.debug(f"GET stream max reconnection attempts ({MAX_RECONNECTION_ATTEMPTS}) exceeded")

tests/shared/test_streamable_http.py

@@ -1303,18 +1303,18 @@ async def run_tool():
                 tg.cancel_scope.cancel()
 
     # Verify we received exactly one notification
-    assert len(captured_notifications) == 1  # pragma: lax no cover
-    assert isinstance(captured_notifications[0], types.LoggingMessageNotification)  # pragma: lax no cover
-    assert captured_notifications[0].params.data == "First notification before lock"  # pragma: lax no cover
+    assert len(captured_notifications) == 1
+    assert isinstance(captured_notifications[0], types.LoggingMessageNotification)
+    assert captured_notifications[0].params.data == "First notification before lock"
 
     # Clear notifications for the second phase
-    captured_notifications = []  # pragma: lax no cover
+    captured_notifications = []
 
     # Now resume the session with the same mcp-session-id and protocol version
-    headers: dict[str, Any] = {}  # pragma: lax no cover
-    if captured_session_id:  # pragma: lax no cover
+    headers: dict[str, Any] = {}
+    if captured_session_id:
         headers[MCP_SESSION_ID_HEADER] = captured_session_id
-    if captured_protocol_version:  # pragma: lax no cover
+    if captured_protocol_version:
         headers[MCP_PROTOCOL_VERSION_HEADER] = captured_protocol_version
 
     async with create_mcp_http_client(headers=headers) as httpx_client:
@@ -1346,8 +1346,8 @@ async def run_tool():
                 # We should have received the remaining notifications
                 assert len(captured_notifications) == 1
 
-            assert isinstance(captured_notifications[0], types.LoggingMessageNotification)  # pragma: lax no cover
-            assert captured_notifications[0].params.data == "Second notification after lock"  # pragma: lax no cover
+            assert isinstance(captured_notifications[0], types.LoggingMessageNotification)
+            assert captured_notifications[0].params.data == "Second notification after lock"
 
 
 @pytest.mark.anyio