Python sync to async

sync_to_async.py

import asyncio
import inspect
import functools


def async_(fn):
    """
    Wrap the given function into a coroutine function.
    
    If the function returns a coroutine, that coroutine is awaited and its
    value will be the return value. Otherwise the initial return value will
    be the return value.
    """
    if inspect.iscoroutinefunction(fn):
        return fn

    @functools.wraps(fn)
    async def wrapper(*args, **kwargs):
        result = fn(*args, **kwargs)
        if inspect.iscoroutine(result):
            result = await result
        return result

    return wrapper


def async_concurrent(fn):
    """
    Ensure function is converted into coroutine function.
    Coroutine functions are left untouched. 
    
    Regular functions are executed in the default asyncio thread pool.
    It won't work for regular functions that return a coroutine since that coroutine will be
    created in another thread (and therefore another event loop) and cannot be await by the
    calling thread.
    """
    if inspect.iscoroutinefunction(fn):
        return fn
    @functools.wraps(fn)
    async def wrapper(*args, **kwargs):
        return await asyncio.to_thread(fn, *args, **kwargs)
    return wrapper