fix: remove unnecessary pragma: no cover from test files

Remove ~100 unnecessary '# pragma: no cover' annotations from 30 test
files. These lines are actually covered by tests, as detected by
strict-no-cover in CI.

Author: maxisbey

tests/client/auth/extensions/test_client_credentials.py

@@ -23,10 +23,10 @@ def __init__(self):
         self._tokens: OAuthToken | None = None
         self._client_info: OAuthClientInformationFull | None = None
 
-    async def get_tokens(self) -> OAuthToken | None:  # pragma: no cover
+    async def get_tokens(self) -> OAuthToken | None:
         return self._tokens
 
-    async def set_tokens(self, tokens: OAuthToken) -> None:  # pragma: no cover
+    async def set_tokens(self, tokens: OAuthToken) -> None:
         self._tokens = tokens
 
     async def get_client_info(self) -> OAuthClientInformationFull | None:  # pragma: no cover

tests/client/conftest.py

@@ -40,7 +40,7 @@ def clear(self) -> None:
         self.client.sent_messages.clear()
         self.server.sent_messages.clear()
 
-    def get_client_requests(self, method: str | None = None) -> list[JSONRPCRequest]:  # pragma: no cover
+    def get_client_requests(self, method: str | None = None) -> list[JSONRPCRequest]:
         """Get client-sent requests, optionally filtered by method."""
         return [
             req.message

tests/client/test_auth.py

@@ -1696,7 +1696,7 @@ async def callback_handler() -> tuple[str, str | None]:
         final_response = httpx.Response(200, request=final_request)
         try:
             await auth_flow.asend(final_response)
-        except StopAsyncIteration:  # pragma: no cover
+        except StopAsyncIteration:
             pass
 
     @pytest.mark.anyio

tests/client/test_notification_response.py

@@ -94,7 +94,7 @@ def non_sdk_server(non_sdk_server_port: int) -> Generator[None, None, None]:
     proc.start()
 
     # Wait for server to be ready
-    try:  # pragma: no cover
+    try:
         wait_for_server(non_sdk_server_port, timeout=10.0)
     except TimeoutError:  # pragma: no cover
         proc.kill()

tests/client/test_stdio.py

@@ -157,7 +157,7 @@ async def test_stdio_client_universal_cleanup():
 
 @pytest.mark.anyio
 @pytest.mark.skipif(sys.platform == "win32", reason="Windows signal handling is different")
-async def test_stdio_client_sigint_only_process():  # pragma: no cover
+async def test_stdio_client_sigint_only_process():
     """Test cleanup with a process that ignores SIGTERM but responds to SIGINT."""
     # Create a Python script that ignores SIGTERM but handles SIGINT
     script_content = textwrap.dedent(
@@ -481,7 +481,7 @@ def handle_term(sig, frame):
             await anyio.sleep(0.5)
 
             # Verify child is writing
-            if os.path.exists(marker_file):  # pragma: no cover
+            if os.path.exists(marker_file):
                 size1 = os.path.getsize(marker_file)
                 await anyio.sleep(0.3)
                 size2 = os.path.getsize(marker_file)

tests/client/transports/test_memory.py

@@ -34,15 +34,13 @@ def fastmcp_server() -> FastMCP:
     """Create a FastMCP server for testing."""
     server = FastMCP("test")
 
-    # pragma: no cover on handlers below - they exist only to register capabilities.
-    # Transport tests verify stream creation and basic protocol, not handler invocation.
     @server.tool()
-    def greet(name: str) -> str:  # pragma: no cover
+    def greet(name: str) -> str:
         """Greet someone by name."""
         return f"Hello, {name}!"
 
     @server.resource("test://resource")
-    def test_resource() -> str:  # pragma: no cover
+    def test_resource() -> str:
         """A test resource."""
         return "Test content"
 

tests/experimental/tasks/server/test_server.py

@@ -310,8 +310,7 @@ async def run_server():
             async with anyio.create_task_group() as tg:
 
                 async def handle_messages():
-                    # TODO(Marcelo): Drop the pragma once https://github.com/coveragepy/coveragepy/issues/1987 is fixed.
-                    async for message in server_session.incoming_messages:  # pragma: no cover
+                    async for message in server_session.incoming_messages:
                         await server._handle_message(message, server_session, {}, False)
 
                 tg.start_soon(handle_messages)
@@ -388,8 +387,8 @@ async def run_server():
             ),
         ) as server_session:
             async with anyio.create_task_group() as tg:
-                # TODO(Marcelo): Drop the pragma once https://github.com/coveragepy/coveragepy/issues/1987 is fixed.
-                async def handle_messages():  # pragma: no cover
+
+                async def handle_messages():
                     async for message in server_session.incoming_messages:
                         await server._handle_message(message, server_session, {}, False)
 
@@ -573,7 +572,7 @@ async def test_build_elicit_form_request() -> None:
             assert (
                 request_with_task.params["_meta"]["io.modelcontextprotocol/related-task"]["taskId"] == "test-task-123"
             )
-    finally:  # pragma: no cover
+    finally:
         await server_to_client_send.aclose()
         await server_to_client_receive.aclose()
         await client_to_server_send.aclose()
@@ -619,7 +618,7 @@ async def test_build_elicit_url_request() -> None:
             assert (
                 request_with_task.params["_meta"]["io.modelcontextprotocol/related-task"]["taskId"] == "test-task-789"
             )
-    finally:  # pragma: no cover
+    finally:
         await server_to_client_send.aclose()
         await server_to_client_receive.aclose()
         await client_to_server_send.aclose()
@@ -670,7 +669,7 @@ async def test_build_create_message_request() -> None:
                 request_with_task.params["_meta"]["io.modelcontextprotocol/related-task"]["taskId"]
                 == "sampling-task-456"
             )
-    finally:  # pragma: no cover
+    finally:
         await server_to_client_send.aclose()
         await server_to_client_receive.aclose()
         await client_to_server_send.aclose()
@@ -707,7 +706,7 @@ async def test_send_message() -> None:
             received = await server_to_client_receive.receive()
             assert isinstance(received.message, JSONRPCNotification)
             assert received.message.method == "test/notification"
-    finally:  # pragma: no cover
+    finally:
         await server_to_client_send.aclose()
         await server_to_client_receive.aclose()
         await client_to_server_send.aclose()
@@ -761,7 +760,7 @@ def route_error(self, request_id: str | int, error: ErrorData) -> bool:
             assert len(routed_responses) == 1
             assert routed_responses[0]["id"] == "test-req-1"
             assert routed_responses[0]["response"]["status"] == "ok"
-    finally:  # pragma: no cover
+    finally:
         await server_to_client_send.aclose()
         await server_to_client_receive.aclose()
         await client_to_server_send.aclose()
@@ -816,7 +815,7 @@ def route_error(self, request_id: str | int, error: ErrorData) -> bool:
             assert len(routed_errors) == 1
             assert routed_errors[0]["id"] == "test-req-2"
             assert routed_errors[0]["error"].message == "Test error"
-    finally:  # pragma: no cover
+    finally:
         await server_to_client_send.aclose()
         await server_to_client_receive.aclose()
         await client_to_server_send.aclose()
@@ -874,7 +873,7 @@ def route_error(self, request_id: str | int, error: ErrorData) -> bool:
 
             # Verify both routers were called (first returned False, second returned True)
             assert router_calls == ["non_matching_response", "matching_response"]
-    finally:  # pragma: no cover
+    finally:
         await server_to_client_send.aclose()
         await server_to_client_receive.aclose()
         await client_to_server_send.aclose()
@@ -933,7 +932,7 @@ def route_error(self, request_id: str | int, error: ErrorData) -> bool:
 
             # Verify both routers were called (first returned False, second returned True)
             assert router_calls == ["non_matching_error", "matching_error"]
-    finally:  # pragma: no cover
+    finally:
         await server_to_client_send.aclose()
         await server_to_client_receive.aclose()
         await client_to_server_send.aclose()

tests/issues/test_1027_win_unreachable_cleanup.py

@@ -102,7 +102,7 @@ def echo(text: str) -> str:
 
         # Give server a moment to complete cleanup
         with anyio.move_on_after(5.0):
-            while not Path(cleanup_marker).exists():  # pragma: no cover
+            while not Path(cleanup_marker).exists():
                 await anyio.sleep(0.1)
 
         # Verify cleanup marker was created - this works now that stdio_client
@@ -113,9 +113,9 @@ def echo(text: str) -> str:
     finally:
         # Clean up files
         for path in [server_script, startup_marker, cleanup_marker]:
-            try:  # pragma: no cover
+            try:
                 Path(path).unlink()
-            except FileNotFoundError:  # pragma: no cover
+            except FileNotFoundError:
                 pass
 
 
@@ -224,7 +224,7 @@ def echo(text: str) -> str:
 
         # Check if cleanup ran
         with anyio.move_on_after(5.0):
-            while not Path(cleanup_marker).exists():  # pragma: no cover
+            while not Path(cleanup_marker).exists():
                 await anyio.sleep(0.1)
 
         # Verify the cleanup ran - stdin closure enables graceful shutdown
@@ -234,7 +234,7 @@ def echo(text: str) -> str:
     finally:
         # Clean up files
         for path in [server_script, startup_marker, cleanup_marker]:
-            try:  # pragma: no cover
+            try:
                 Path(path).unlink()
-            except FileNotFoundError:  # pragma: no cover
+            except FileNotFoundError:
                 pass

tests/issues/test_129_resource_templates.py

@@ -33,10 +33,10 @@ def get_user_profile(user_id: str) -> str:  # pragma: no cover
     assert len(templates) == 2
 
     # Verify template details
-    greeting_template = next(t for t in templates if t.name == "get_greeting")  # pragma: no cover
+    greeting_template = next(t for t in templates if t.name == "get_greeting")
     assert greeting_template.uri_template == "greeting://{name}"
     assert greeting_template.description == "Get a personalized greeting"
 
-    profile_template = next(t for t in templates if t.name == "get_user_profile")  # pragma: no cover
+    profile_template = next(t for t in templates if t.name == "get_user_profile")
     assert profile_template.uri_template == "users://{user_id}/profile"
     assert profile_template.description == "Dynamic user data"

tests/issues/test_1363_race_condition_streamable_http.py

@@ -99,7 +99,7 @@ def check_logs_for_race_condition_errors(caplog: pytest.LogCaptureFixture, test_
     # Check for specific race condition errors in logs
     errors_found: list[str] = []
 
-    for record in caplog.records:  # pragma: no cover
+    for record in caplog.records:
         message = record.getMessage()
         if "ClosedResourceError" in message:
             errors_found.append("ClosedResourceError")