Merge branch 'srothh/async-transport-integration' into srothh/async-task-identifier

Author: srothh

sentry_sdk/transport.py

@@ -7,7 +7,6 @@
 import ssl
 import time
 import asyncio
-
 from datetime import datetime, timedelta, timezone
 from collections import defaultdict
 from urllib.request import getproxies
@@ -602,7 +601,6 @@ def __init__(self: Self, options: Dict[str, Any]) -> None:
             super().__init__(options)
             # Requires event loop at init time
             self.loop = asyncio.get_running_loop()
-            self.background_tasks: set[asyncio.Task[None]] = set()
 
         def _create_worker(self: Self, options: dict[str, Any]) -> Worker:
             return AsyncWorker(queue_size=options["transport_queue_size"])
@@ -800,9 +798,6 @@ def kill(self: Self) -> Optional[asyncio.Task[None]]:  # type: ignore
 
             logger.debug("Killing HTTP transport")
             self._worker.kill()
-            for task in self.background_tasks:
-                task.cancel()
-            self.background_tasks.clear()
             try:
                 # Return the pool cleanup task so caller can await it if needed
                 with mark_sentry_task_internal():

tests/test_transport.py

@@ -880,9 +880,7 @@ async def send_message(i):
 
     tasks = [send_message(i) for i in range(num_messages)]
     await asyncio.gather(*tasks)
-    transport = client.transport
     await client.close(timeout=2.0)
-    assert len(transport.background_tasks) == 0
     assert len(capturing_server.captured) == num_messages