.

Author: alexander-alderman-webb

sentry_sdk/integrations/starlette.py

@@ -668,7 +668,7 @@ async def extract_request_info(self):
                 and "sentry_sdk.is_body_cached" in self.request.scope["state"]
                 and self.request.scope["state"]["sentry_sdk.is_body_cached"]
             )
-            if await self.request.is_disconnected() and not is_body_cached:
+            if not is_body_cached:
                 request_info["data"] = (
                     AnnotatedValue.removed_because_body_consumed_and_not_cached()
                 )

tests/integrations/fastapi/test_fastapi.py

@@ -1,3 +1,4 @@
+import asyncio
 import json
 import logging
 import pytest
@@ -86,7 +87,7 @@ async def _consume_stream_body(request):
         # Avoid cache by constructing new request
         wrapped_request = Request(request.scope, request.receive)
 
-        assert await wrapped_request.json() == BODY_JSON
+        assert await asyncio.wait_for(wrapped_request.json(), timeout=1.0) == BODY_JSON
 
         return {"status": "ok"}
 

tests/integrations/starlette/test_starlette.py

@@ -518,7 +518,7 @@ async def _consume_stream_body(request):
         # Avoid cache by constructing new request
         wrapped_request = Request(request.scope, request.receive)
 
-        assert await wrapped_request.json() == BODY_JSON
+        assert await asyncio.wait_for(wrapped_request.json(), timeout=1.0) == BODY_JSON
 
         return starlette.responses.JSONResponse({"status": "ok"})