Merge pull request #229 from tomchristie/run-in-threadpool

Use Starlette's run_in_threadpool

responder/background.py

@@ -3,6 +3,7 @@
 import concurrent.futures
 import multiprocessing
 import traceback
+from starlette.concurrency import run_in_threadpool
 
 
 class BackgroundQueue:
@@ -40,6 +41,4 @@ async def __call__(self, func, *args, **kwargs) -> None:
         if asyncio.iscoroutinefunction(func):
             return await asyncio.ensure_future(func(*args, **kwargs))
         else:
-            fn = functools.partial(func, *args, **kwargs)
-            loop = asyncio.get_event_loop()
-            return await loop.run_in_executor(None, fn)
+            return await run_in_threadpool(func, *args, **kwargs)

setup.py

@@ -22,7 +22,7 @@
     sys.exit()
 
 required = [
-    "starlette",
+    "starlette<0.9",
     "uvicorn",
     "aiofiles",
     "pyyaml",