diff --git a/appPublic/worker.py b/appPublic/worker.py index 152b3fc..773c2f5 100755 --- a/appPublic/worker.py +++ b/appPublic/worker.py @@ -2,6 +2,14 @@ import random import asyncio import inspect from functools import wraps +from functools import wraps + +def awaitify(sync_func): + """Wrap a synchronous callable to allow ``await``'ing it""" + @wraps(sync_func) + async def async_func(*args, **kwargs): + return sync_func(*args, **kwargs) + return async_func def to_func(func): @wraps(func)