Orchestrator-Based Persistence

Wrap any agent with persistence using PersistenceOrchestrator — alternative to MemoryConfig(db=PraisonAIDB(…))

Wrap an existing agent so every chat is saved and can be resumed, without changing how you build the agent.

Quick Start

1. Simple Usage

   from praisonaiagents import Agent
   from praisonai.persistence import PersistenceOrchestrator, wrap_agent_with_persistence
   from praisonai.persistence.conversation.sqlite import SQLiteConversationStore
   
   store = SQLiteConversationStore(path="conv.db")
   orchestrator = PersistenceOrchestrator(conversation_store=store)
   
   agent = wrap_agent_with_persistence(
       Agent(name="Assistant", instructions="You are helpful."),
       orchestrator,
       session_id="my-session",
   )
   
   agent.chat("Hello!")           # user + assistant message both persisted
   print(agent.get_messages())    # read back from the store
   agent.end_session()

2. Resume on Next Run

   # Later, in a fresh process — same session_id
   resumed = wrap_agent_with_persistence(
       Agent(name="Assistant", instructions="You are helpful."),
       orchestrator,
       session_id="my-session",   # auto_resume=True by default
   )
   
   resumed.chat("What did I say earlier?")   # chat_history pre-populated before answering

Which Entry Point?

Pick the style that matches how much control you need.

How It Works

Each entry point drives the same orchestrator lifecycle.

Entry Points

wrap_agent_with_persistence

Patches chat (and achat, if the agent has it) on the agent you pass in, and returns that same agent.

Helpers added to the agent:

PersistentAgent

Wraps the agent without patching it. Same options and helpers as above, plus a session_id property. Other attributes pass through to the wrapped agent.

from praisonaiagents import Agent
from praisonai.persistence import PersistentAgent

base = Agent(name="Assistant", instructions="You are helpful.")
agent = PersistentAgent(base, orchestrator, session_id="s3")

agent.name           # "Assistant" — attribute delegated to base
agent.session_id     # "s3"
agent.chat("hi")

await agent.achat(...) works even if the wrapped agent has no achat — it runs chat in a worker thread.

create_persistent_session

A with block for logging messages by hand.

from praisonai.persistence import create_persistent_session

with create_persistent_session(orchestrator, session_id="s4") as session:
    session.persist_message("user", "hi")
    session.persist_message("assistant", "hello")
# on_agent_end fires automatically on exit

Common Patterns

agent = wrap_agent_with_persistence(
    Agent(name="Assistant", instructions="You are helpful."),
    orchestrator,
    session_id="scratch",
    auto_resume=False,
)

agent = PersistentAgent(
    Agent(name="Assistant", instructions="You are helpful."),
    orchestrator,
    session_id="chat-alice",
    user_id="alice",
)

import asyncio

async def main():
    agent = PersistentAgent(
        Agent(name="Assistant", instructions="You are helpful."),
        orchestrator,
        session_id="async-1",
    )
    await agent.achat("Hello!")
    await agent.aend_session()

asyncio.run(main())

Best Practices

Related