pass related request id on progress to allow this to trigger event id in sse

Author: davemssavage

src/mcp/server/fastmcp/server.py

@@ -1088,6 +1088,7 @@ async def report_progress(self, progress: float, total: float | None = None, mes
             progress=progress,
             total=total,
             message=message,
+            related_request_id=self.request_context.request_id,
         )
 
     async def read_resource(self, uri: str | AnyUrl) -> Iterable[ReadResourceContents]:

src/mcp/server/session.py

@@ -301,7 +301,7 @@ async def send_progress_notification(
         progress: float,
         total: float | None = None,
         message: str | None = None,
-        related_request_id: str | None = None,
+        related_request_id: types.RequestId | None = None,
     ) -> None:
         """Send a progress notification."""
         await self.send_notification(

tests/issues/test_176_progress_token.py

@@ -36,6 +36,6 @@ async def test_progress_token_zero_first_call():
 
     # Verify progress notifications
     assert mock_session.send_progress_notification.call_count == 3, "All progress notifications should be sent"
-    mock_session.send_progress_notification.assert_any_call(progress_token=0, progress=0.0, total=10.0, message=None)
-    mock_session.send_progress_notification.assert_any_call(progress_token=0, progress=5.0, total=10.0, message=None)
-    mock_session.send_progress_notification.assert_any_call(progress_token=0, progress=10.0, total=10.0, message=None)
+    mock_session.send_progress_notification.assert_any_call(progress_token=0, progress=0.0, total=10.0, message=None, related_request_id='test-request')
+    mock_session.send_progress_notification.assert_any_call(progress_token=0, progress=5.0, total=10.0, message=None, related_request_id='test-request')
+    mock_session.send_progress_notification.assert_any_call(progress_token=0, progress=10.0, total=10.0, message=None, related_request_id='test-request')