Skip to content

Commit 21cde52

Browse files
committed
fix(transport): Fix fallback sync transport creating async worker
GH-4582
1 parent 3629609 commit 21cde52

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

sentry_sdk/transport.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -227,7 +227,11 @@ def __init__(self: Self, options: Dict[str, Any]) -> None:
227227

228228
def _create_worker(self, options: dict[str, Any]) -> Worker:
229229
async_enabled = options.get("_experiments", {}).get("transport_async", False)
230-
worker_cls = AsyncWorker if async_enabled else BackgroundWorker
230+
try:
231+
asyncio.get_running_loop()
232+
worker_cls = AsyncWorker if async_enabled else BackgroundWorker
233+
except RuntimeError:
234+
worker_cls = BackgroundWorker
231235
return worker_cls(queue_size=options["transport_queue_size"])
232236

233237
def record_lost_event(

0 commit comments

Comments
 (0)