Renames

Author: ericapisani

sentry_sdk/integrations/fastapi.py

@@ -20,7 +20,7 @@
     from sentry_sdk.integrations.starlette import (
         StarletteIntegration,
         StarletteRequestExtractor,
-        _set_body_data_on_streaming_segment,
+        _set_request_body_data_on_streaming_segment,
     )
 except DidNotEnable:
     raise DidNotEnable("Starlette is not installed")
@@ -141,7 +141,7 @@ def event_processor(event: "Event", hint: "Dict[str, Any]") -> "Event":
             )
 
             if has_span_streaming_enabled(client.options):
-                _set_body_data_on_streaming_segment(info)
+                _set_request_body_data_on_streaming_segment(info)
 
             return await old_app(*args, **kwargs)
 

sentry_sdk/integrations/starlette.py

@@ -234,7 +234,7 @@ async def _sentry_send(*args: "Any", **kwargs: "Any") -> "Any":
     return middleware_class
 
 
-def _serialize_body_data(data: "Any") -> str:
+def _serialize_request_body_data(data: "Any") -> str:
     # data may be a JSON-serializable value, an AnnotatedValue, or a dict with AnnotatedValue values
     def _default(value: "Any") -> "Any":
         if isinstance(value, AnnotatedValue):
@@ -244,7 +244,7 @@ def _default(value: "Any") -> "Any":
     return json.dumps(data, default=_default)
 
 
-def _set_body_data_on_streaming_segment(
+def _set_request_body_data_on_streaming_segment(
     info: "Optional[Dict[str, Any]]",
 ) -> None:
     current_span = sentry_sdk.get_current_span()
@@ -256,7 +256,7 @@ def _set_body_data_on_streaming_segment(
     ):
         current_span._segment.set_attribute(
             "http.request.body.data",
-            _serialize_body_data(info["data"]),
+            _serialize_request_body_data(info["data"]),
         )
 
 
@@ -527,7 +527,7 @@ def event_processor(
                 )
 
                 if has_span_streaming_enabled(client.options):
-                    _set_body_data_on_streaming_segment(info)
+                    _set_request_body_data_on_streaming_segment(info)
 
                 return await old_func(*args, **kwargs)