fix(worker): Check if callbacks from worker queue are coroutines or functions

Add a check to see wheter callbacks are awaitable coroutines or functions, as coroutines need to be awaited.

GH-4581

Author: srothh

sentry_sdk/worker.py

@@ -3,6 +3,7 @@
 import os
 import threading
 import asyncio
+import inspect
 
 from time import sleep, time
 from sentry_sdk._queue import Queue, FullError
@@ -271,7 +272,12 @@ async def _target(self) -> None:
         while True:
             callback = await self._queue.get()
             try:
-                callback()
+                if inspect.iscoroutinefunction(callback):
+                    # Callback is an async coroutine, need to await it
+                    await callback()
+                else:
+                    # Callback is a sync function, need to call it
+                    callback()
             except Exception:
                 logger.error("Failed processing job", exc_info=True)
             finally: