def run_async(coroutine):
    """Helper function to run async code synchronously."""
    with ThreadPoolExecutor() as pool:
        return pool.submit(asyncio.run, coroutine).result()
Helper function to run async code synchronously.
py/migrations/versions/2fac23e4d91b_migrate_to_document_search.py