test(transport): Add AsyncIO integration to async transport tests

GH-4601

Author: srothh

tests/test_transport.py

@@ -33,6 +33,7 @@
     AsyncHttpTransport,
 )
 from sentry_sdk.integrations.logging import LoggingIntegration, ignore_logger
+from sentry_sdk.integrations.asyncio import AsyncioIntegration
 
 
 server = None
@@ -182,6 +183,7 @@ async def test_transport_works_async(
     client = make_client(
         debug=debug,
         _experiments=experiments,
+        integrations=[AsyncioIntegration()],
     )
 
     if use_pickle:
@@ -811,7 +813,7 @@ async def test_async_transport_background_thread_capture(
     """Test capture_envelope from background threads uses run_coroutine_threadsafe"""
     caplog.set_level(logging.DEBUG)
     experiments = {"transport_async": True}
-    client = make_client(_experiments=experiments)
+    client = make_client(_experiments=experiments, integrations=[AsyncioIntegration()])
     assert isinstance(client.transport, AsyncHttpTransport)
     sentry_sdk.get_global_scope().set_client(client)
     captured_from_thread = []
@@ -842,7 +844,7 @@ async def test_async_transport_event_loop_closed_scenario(
     """Test behavior when trying to capture after event loop context ends"""
     caplog.set_level(logging.DEBUG)
     experiments = {"transport_async": True}
-    client = make_client(_experiments=experiments)
+    client = make_client(_experiments=experiments, integrations=[AsyncioIntegration()])
     sentry_sdk.get_global_scope().set_client(client)
     original_loop = client.transport.loop
 
@@ -868,7 +870,7 @@ async def test_async_transport_concurrent_requests(
     """Test multiple simultaneous envelope submissions"""
     caplog.set_level(logging.DEBUG)
     experiments = {"transport_async": True}
-    client = make_client(_experiments=experiments)
+    client = make_client(_experiments=experiments, integrations=[AsyncioIntegration()])
     assert isinstance(client.transport, AsyncHttpTransport)
     sentry_sdk.get_global_scope().set_client(client)
 
@@ -892,7 +894,7 @@ async def test_async_transport_rate_limiting_with_concurrency(
 ):
     """Test async transport rate limiting with concurrent requests"""
     experiments = {"transport_async": True}
-    client = make_client(_experiments=experiments)
+    client = make_client(_experiments=experiments, integrations=[AsyncioIntegration()])
 
     assert isinstance(client.transport, AsyncHttpTransport)
     sentry_sdk.get_global_scope().set_client(client)
@@ -930,6 +932,7 @@ async def test_async_two_way_ssl_authentication():
         cert_file=cert_file,
         key_file=key_file,
         _experiments={"transport_async": True},
+        integrations=[AsyncioIntegration()],
     )
     assert isinstance(client.transport, AsyncHttpTransport)