@@ -28,7 +28,7 @@
 
 def async_to_sync(obj, name):
     function = getattr(obj, name)
-    loop = asyncio.get_event_loop()
+    main_loop = asyncio.get_event_loop()
 
     async def consume_generator(coroutine):
         return [i async for i in coroutine]
@@ -37,6 +37,11 @@ async def consume_generator(coroutine):
     def async_to_sync_wrap(*args, **kwargs):
         coroutine = function(*args, **kwargs)
 
+        try:
+            loop = asyncio.get_event_loop()
+        except RuntimeError:
+            loop = main_loop
+
         if loop.is_running():
             if threading.current_thread() is threading.main_thread():
                 return coroutine