add pragmas

Author: Kludex

pyproject.toml

@@ -64,7 +64,7 @@ dev = [
     "pytest-pretty>=1.2.0",
     "inline-snapshot>=0.23.0",
     "dirty-equals>=0.9.0",
-    "coverage[toml]==7.10.7",
+    "coverage[toml]>=7.13.1",
     "pillow>=12.0",
 ]
 docs = [

src/mcp/server/fastmcp/utilities/context_injection.py

@@ -25,7 +25,8 @@ def find_context_parameter(fn: Callable[..., Any]) -> str | None:
     # Get type hints to properly resolve string annotations
     try:
         hints = typing.get_type_hints(fn)
-    except Exception:
+    # TODO(Marcelo): Drop the pragma once https://github.com/coveragepy/coveragepy/issues/1987 is fixed.
+    except Exception:  # pragma: no cover
         # If we can't resolve type hints, we can't find the context parameter
         return None
 

src/mcp/server/session.py

@@ -702,7 +702,5 @@ async def _handle_incoming(self, req: ServerRequestResponder) -> None:
         await self._incoming_message_stream_writer.send(req)
 
     @property
-    def incoming_messages(
-        self,
-    ) -> MemoryObjectReceiveStream[ServerRequestResponder]:
+    def incoming_messages(self) -> MemoryObjectReceiveStream[ServerRequestResponder]:
         return self._incoming_message_stream_reader

tests/experimental/tasks/server/test_server.py

@@ -312,7 +312,8 @@ async def run_server():
             async with anyio.create_task_group() as tg:
 
                 async def handle_messages():
-                    async for message in server_session.incoming_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
                         await server._handle_message(message, server_session, {}, False)
 
                 tg.start_soon(handle_messages)
@@ -391,8 +392,8 @@ async def run_server():
             ),
         ) as server_session:
             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 def handle_messages():  # pragma: no cover
                     async for message in server_session.incoming_messages:
                         await server._handle_message(message, server_session, {}, False)
 

tests/server/test_lowlevel_input_validation.py

@@ -70,7 +70,8 @@ async def run_server():
             async with anyio.create_task_group() as tg:
 
                 async def handle_messages():
-                    async for message in server_session.incoming_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
                         await server._handle_message(message, server_session, {}, False)
 
                 tg.start_soon(handle_messages)

tests/server/test_lowlevel_output_validation.py

@@ -71,7 +71,8 @@ async def run_server():
             async with anyio.create_task_group() as tg:
 
                 async def handle_messages():
-                    async for message in server_session.incoming_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
                         await server._handle_message(message, server_session, {}, False)
 
                 tg.start_soon(handle_messages)

tests/server/test_lowlevel_tool_annotations.py

@@ -67,7 +67,8 @@ async def run_server():
             async with anyio.create_task_group() as tg:
 
                 async def handle_messages():
-                    async for message in server_session.incoming_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
                         await server._handle_message(message, server_session, {}, False)
 
                 tg.start_soon(handle_messages)

tests/server/test_session.py

@@ -410,11 +410,9 @@ async def test_create_message_tool_result_validation():
 
             # Case 8: empty messages list - skips validation entirely
             # Covers the `if messages:` branch (line 280->302)
-            with anyio.move_on_after(0.01):
-                await session.create_message(
-                    messages=[],
-                    max_tokens=100,
-                )
+            # TODO(Marcelo): Drop the pragma once https://github.com/coveragepy/coveragepy/issues/1987 is fixed.
+            with anyio.move_on_after(0.01):  # pragma: no cover
+                await session.create_message(messages=[], max_tokens=100)
 
 
 @pytest.mark.anyio

tests/shared/test_session.py

@@ -124,7 +124,8 @@ async def make_request(client_session: ClientSession):
             )
 
             # Give cancellation time to process
-            with anyio.fail_after(1):
+            # TODO(Marcelo): Drop the pragma once https://github.com/coveragepy/coveragepy/issues/1987 is fixed.
+            with anyio.fail_after(1):  # pragma: no cover
                 await ev_cancelled.wait()
 
 
@@ -176,7 +177,8 @@ async def make_request(client_session: ClientSession):
             tg.start_soon(mock_server)
             tg.start_soon(make_request, client_session)
 
-            with anyio.fail_after(2):
+            # TODO(Marcelo): Drop the pragma once https://github.com/coveragepy/coveragepy/issues/1987 is fixed.
+            with anyio.fail_after(2):  # pragma: no cover
                 await ev_response_received.wait()
 
     assert len(result_holder) == 1
@@ -232,7 +234,8 @@ async def make_request(client_session: ClientSession):
             tg.start_soon(mock_server)
             tg.start_soon(make_request, client_session)
 
-            with anyio.fail_after(2):
+            # TODO(Marcelo): Drop the pragma once https://github.com/coveragepy/coveragepy/issues/1987 is fixed.
+            with anyio.fail_after(2):  # pragma: no cover
                 await ev_error_received.wait()
 
     assert len(error_holder) == 1
@@ -287,7 +290,8 @@ async def make_request(client_session: ClientSession):
             tg.start_soon(mock_server)
             tg.start_soon(make_request, client_session)
 
-            with anyio.fail_after(2):
+            # TODO(Marcelo): Drop the pragma once https://github.com/coveragepy/coveragepy/issues/1987 is fixed.
+            with anyio.fail_after(2):  # pragma: no cover
                 await ev_timeout.wait()
 
 
@@ -333,7 +337,8 @@ async def mock_server():
             tg.start_soon(make_request, client_session)
             tg.start_soon(mock_server)
 
-            with anyio.fail_after(1):
+            # TODO(Marcelo): Drop the pragma once https://github.com/coveragepy/coveragepy/issues/1987 is fixed.
+            with anyio.fail_after(1):  # pragma: no cover
                 await ev_closed.wait()
-            with anyio.fail_after(1):
+            with anyio.fail_after(1):  # pragma: no cover
                 await ev_response.wait()