test(httpx): Wrap streaming tests in parent span

The streaming child-span guard added for HTTP client integrations skips
child-span creation when there is no current span. The httpx2 and
strawberry tests were updated for this, but the equivalent httpx
streaming tests were missed, so no HTTP client span was produced and
the tests failed with StopIteration.

Wrap each streaming test's request in a parent span so a child HTTP
client span is created, mirroring the httpx2 test updates.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: 2 people

tests/integrations/httpx/test_httpx.py

@@ -739,10 +739,13 @@ def test_outgoing_trace_headers_span_streaming(
 
     items = capture_items("span")
 
-    if asyncio.iscoroutinefunction(httpx_client.get):
-        response = asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
-    else:
-        response = httpx_client.get(url)
+    with sentry_sdk.traces.start_span(name="test"):
+        if asyncio.iscoroutinefunction(httpx_client.get):
+            response = asyncio.get_event_loop().run_until_complete(
+                httpx_client.get(url)
+            )
+        else:
+            response = httpx_client.get(url)
 
     sentry_sdk.flush()
 
@@ -781,12 +784,13 @@ def test_outgoing_trace_headers_append_to_baggage_span_streaming(
     items = capture_items("span")
 
     with mock.patch("sentry_sdk.tracing_utils.Random.randrange", return_value=500000):
-        if asyncio.iscoroutinefunction(httpx_client.get):
-            response = asyncio.get_event_loop().run_until_complete(
-                httpx_client.get(url, headers={"baGGage": "custom=data"})
-            )
-        else:
-            response = httpx_client.get(url, headers={"baGGage": "custom=data"})
+        with sentry_sdk.traces.start_span(name="test"):
+            if asyncio.iscoroutinefunction(httpx_client.get):
+                response = asyncio.get_event_loop().run_until_complete(
+                    httpx_client.get(url, headers={"baGGage": "custom=data"})
+                )
+            else:
+                response = httpx_client.get(url, headers={"baGGage": "custom=data"})
 
     sentry_sdk.flush()
 
@@ -820,10 +824,11 @@ def test_request_source_disabled_span_streaming(
 
     url = "http://example.com/"
 
-    if asyncio.iscoroutinefunction(httpx_client.get):
-        asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
-    else:
-        httpx_client.get(url)
+    with sentry_sdk.traces.start_span(name="test"):
+        if asyncio.iscoroutinefunction(httpx_client.get):
+            asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
+        else:
+            httpx_client.get(url)
 
     sentry_sdk.flush()
 
@@ -864,10 +869,11 @@ def test_request_source_enabled_span_streaming(
 
     url = "http://example.com/"
 
-    if asyncio.iscoroutinefunction(httpx_client.get):
-        asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
-    else:
-        httpx_client.get(url)
+    with sentry_sdk.traces.start_span(name="test"):
+        if asyncio.iscoroutinefunction(httpx_client.get):
+            asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
+        else:
+            httpx_client.get(url)
 
     sentry_sdk.flush()
 
@@ -900,10 +906,11 @@ def test_request_source_span_streaming(
 
     url = "http://example.com/"
 
-    if asyncio.iscoroutinefunction(httpx_client.get):
-        asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
-    else:
-        httpx_client.get(url)
+    with sentry_sdk.traces.start_span(name="test"):
+        if asyncio.iscoroutinefunction(httpx_client.get):
+            asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
+        else:
+            httpx_client.get(url)
 
     sentry_sdk.flush()
 
@@ -957,16 +964,17 @@ def test_request_source_with_module_in_search_path_span_streaming(
 
     url = "http://example.com/"
 
-    if asyncio.iscoroutinefunction(httpx_client.get):
-        from httpx_helpers.helpers import async_get_request_with_client
+    with sentry_sdk.traces.start_span(name="test"):
+        if asyncio.iscoroutinefunction(httpx_client.get):
+            from httpx_helpers.helpers import async_get_request_with_client
 
-        asyncio.get_event_loop().run_until_complete(
-            async_get_request_with_client(httpx_client, url)
-        )
-    else:
-        from httpx_helpers.helpers import get_request_with_client
+            asyncio.get_event_loop().run_until_complete(
+                async_get_request_with_client(httpx_client, url)
+            )
+        else:
+            from httpx_helpers.helpers import get_request_with_client
 
-        get_request_with_client(httpx_client, url)
+            get_request_with_client(httpx_client, url)
 
     sentry_sdk.flush()
 
@@ -1018,10 +1026,11 @@ def test_no_request_source_if_duration_too_short_span_streaming(
 
     url = "http://example.com/"
 
-    if asyncio.iscoroutinefunction(httpx_client.get):
-        asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
-    else:
-        httpx_client.get(url)
+    with sentry_sdk.traces.start_span(name="test"):
+        if asyncio.iscoroutinefunction(httpx_client.get):
+            asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
+        else:
+            httpx_client.get(url)
 
     sentry_sdk.flush()
 
@@ -1055,10 +1064,11 @@ def test_request_source_if_duration_over_threshold_span_streaming(
 
     url = "http://example.com/"
 
-    if asyncio.iscoroutinefunction(httpx_client.get):
-        asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
-    else:
-        httpx_client.get(url)
+    with sentry_sdk.traces.start_span(name="test"):
+        if asyncio.iscoroutinefunction(httpx_client.get):
+            asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
+        else:
+            httpx_client.get(url)
 
     sentry_sdk.flush()
 
@@ -1107,10 +1117,11 @@ def test_span_origin_span_streaming(
 
     url = "http://example.com/"
 
-    if asyncio.iscoroutinefunction(httpx_client.get):
-        asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
-    else:
-        httpx_client.get(url)
+    with sentry_sdk.traces.start_span(name="test"):
+        if asyncio.iscoroutinefunction(httpx_client.get):
+            asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
+        else:
+            httpx_client.get(url)
 
     sentry_sdk.flush()
 
@@ -1140,10 +1151,11 @@ def test_http_url_attributes_span_streaming(
 
     url = "http://example.com/?foo=bar#frag"
 
-    if asyncio.iscoroutinefunction(httpx_client.get):
-        asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
-    else:
-        httpx_client.get(url)
+    with sentry_sdk.traces.start_span(name="test"):
+        if asyncio.iscoroutinefunction(httpx_client.get):
+            asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
+        else:
+            httpx_client.get(url)
 
     sentry_sdk.flush()
 
@@ -1183,10 +1195,11 @@ def test_http_url_attributes_no_query_or_fragment_span_streaming(
 
     url = "http://example.com/"
 
-    if asyncio.iscoroutinefunction(httpx_client.get):
-        asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
-    else:
-        httpx_client.get(url)
+    with sentry_sdk.traces.start_span(name="test"):
+        if asyncio.iscoroutinefunction(httpx_client.get):
+            asyncio.get_event_loop().run_until_complete(httpx_client.get(url))
+        else:
+            httpx_client.get(url)
 
     sentry_sdk.flush()