(func: Callable[..., Any])
确保可调用对象 `func` 为异步函数，如果不是，则使用 `run_sync`
    包裹，使其在 asyncio 的默认 executor 中运行。
确保可调用对象 `func` 为异步函数，如果不是，则使用 `run_sync`
    包裹，使其在 asyncio 的默认 executor 中运行。
确保可调用对象 func 为异步函数，如果不是，则使用 run_sync 包裹，使其在 asyncio 的默认 executor 中运行。
def ensure_async(func: Callable[..., Any]) -> Callable[..., Awaitable[Any]]:
    """
    确保可调用对象 `func` 为异步函数，如果不是，则使用 `run_sync`
    包裹，使其在 asyncio 的默认 executor 中运行。
    """
    if asyncio.iscoroutinefunction(func):
        return func
    else:
        return run_sync(func)
def ensure_async ( func : Callable [ ... , Any ] ) -> Callable [ ... , Awaitable [ Any ] ] : if asyncio . iscoroutinefunction ( func ) : return func else : return run_sync ( func )