Run synchronous code asynchronously (#304)

caronc · Sep 30, 2020 · 525f386 · 525f386
1 parent c732b16
commit 525f386
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/apprise/py3compat/asyncio.py b/apprise/py3compat/asyncio.py
@@ -25,6 +25,8 @@
 
 import sys
 import asyncio
+from concurrent.futures import ThreadPoolExecutor
+from functools import partial
 from ..URLBase import URLBase
 from ..logger import logger
 
@@ -101,7 +103,12 @@ async def async_notify(self, *args, **kwargs):  # noqa: E999
         Async Notification Wrapper
         """
         try:
-            return self.notify(*args, **kwargs)
+            loop = asyncio.get_event_loop()
+            with ThreadPoolExecutor() as executor:
+                return await loop.run_in_executor(
+                    executor,
+                    partial(self.notify, *args, **kwargs),
+                )
 
         except TypeError:
             # These our our internally thrown notifications