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

Author: srothh

sentry_sdk/transport.py

@@ -7,6 +7,7 @@
 import ssl
 import time
 import asyncio
+
 from datetime import datetime, timedelta, timezone
 from collections import defaultdict
 from urllib.request import getproxies

sentry_sdk/worker.py

@@ -3,7 +3,6 @@
 import os
 import threading
 import asyncio
-import inspect
 
 from time import sleep, time
 from sentry_sdk._queue import Queue, FullError
@@ -306,11 +305,7 @@ async def _target(self) -> None:
 
     async def _process_callback(self, callback: Callable[[], Any]) -> None:
         # Callback is an async coroutine, need to await it
-        if inspect.iscoroutinefunction(callback):
-            await callback()
-        else:
-            # Callback is a sync function, such as _flush_client_reports()
-            callback()
+        await callback()
 
     def _on_task_complete(self, task: asyncio.Task[None]) -> None:
         try: