Async Knowledge Retrieval

import asyncio
from praisonaiagents import Agent

agent = Agent(
    name="Research Assistant",
    instructions="Answer questions using the knowledge base.",
    knowledge=["docs/handbook.pdf"],
)

async def main():
    # Two agents run concurrently; each RAG lookup is offloaded,
    # so the loop stays free instead of serialising the round trips.
    await asyncio.gather(
        agent.arun("Summarise the onboarding policy"),
        agent.arun("What is the refund window?"),
    )

asyncio.run(main())

import asyncio
from praisonai.persistence import PersistenceOrchestrator
from praisonai.persistence.knowledge.base import KnowledgeDocument

orchestrator = PersistenceOrchestrator.from_env()

async def main():
    # Add documents (embeddings already computed)
    await orchestrator.aadd_knowledge(
        documents=[
            KnowledgeDocument(
                id="doc-1",
                content="Refunds are processed within 30 days.",
                embedding=[0.12, 0.85, 0.03],
            )
        ],
        collection="policies",
    )

    # Retrieve without blocking the loop
    docs = await orchestrator.aretrieve_knowledge(
        query_embedding=[0.10, 0.80, 0.05],
        collection="policies",
        limit=3,
    )
    for doc in docs:
        print(doc.content)

asyncio.run(main())