.

Author: sentrivana

sentry_sdk/integrations/asgi.py

@@ -362,13 +362,24 @@ async def _sentry_wrapped_send(
                             reraise(*exc_info)
 
                         finally:
-                            with capture_internal_exceptions():
-                                name, source = self._get_segment_name_and_source(
-                                    self.transaction_style, scope
+                            if isinstance(span, StreamedSpan):
+                                already_set = (
+                                    span is not None
+                                    and span.name != _DEFAULT_TRANSACTION_NAME
+                                    and span.get_attributes().get("sentry.span.source")
+                                    in [
+                                        SegmentSource.COMPONENT.value,
+                                        SegmentSource.ROUTE.value,
+                                        SegmentSource.CUSTOM.value,
+                                    ]
                                 )
-                                if isinstance(span, StreamedSpan):
-                                    span.name = name
-                                    span.set_attribute("sentry.span.source", source)
+                                with capture_internal_exceptions():
+                                    if not already_set:
+                                        name, source = self._get_segment_name_and_source(
+                                            self.transaction_style, scope
+                                        )
+                                        span.name = name
+                                        span.set_attribute("sentry.span.source", source)
         finally:
             _asgi_middleware_applied.set(False)
 

sentry_sdk/traces.py

@@ -259,6 +259,7 @@ def __init__(
         self._name: str = name
         self._active: bool = active
         self._attributes: "Attributes" = {}
+
         if attributes:
             for attribute, value in attributes.items():
                 self.set_attribute(attribute, value)
@@ -287,7 +288,6 @@ def __init__(
         self._span_id: "Optional[str]" = None
 
         self._status = SpanStatus.OK.value
-        self.set_attribute("sentry.span.source", SegmentSource.CUSTOM.value)
 
         self._update_active_thread()
 

tests/conftest.py

@@ -329,7 +329,12 @@ class UnwrappedItem:
 
 @pytest.fixture
 def capture_items(monkeypatch):
-    """Capture envelope payload, unfurling individual items."""
+    """
+    Capture envelope payload, unfurling individual items.
+
+    Makes it easier to work with both events and attribute-based telemetry in
+    one test.
+    """
 
     def inner(*types):
         telemetry = []