Function non_blocking

aura/worker_executor.py:138–145

Wrapper that attempts to convert blocking function into non-blocking if possible for asyncio use

(func, /, *args, **kwargs)

async def non_blocking(func, /, *args, **kwargs):
    """
    Wrapper that attempts to convert blocking function into non-blocking if possible for asyncio use
    """
    if sys.version_info[1] >= 9:  # Available only in py3.9+
        return await asyncio.to_thread(func, *args, **kwargs)
    else:  # Fallback, just call function directly in blocking mode
        return func(*args, **kwargs)