infrastructure-opensearch-connectio-opensearch-vector-store-connection-becomes-unstabl-e0cfec76

THEN Use asyncio.run() to properly manage the event loop for asynchronous operations with AsyncOpenSearch. Ensure the event loop is not already running before performing async calls. Example: define an async function to open/close the client and run it with asyncio.run().

import asyncio
from opensearchpy import AsyncOpenSearch

async def check_opensearch():
    os_client = AsyncOpenSearch('localhost:9200')
    await os_client.info()
    await os_client.close()

asyncio.run(check_opensearch())