llama-agents-dbos 0.4.1

DBOS durable runtime plugin for LlamaIndex Workflows

LlamaAgents DBOS Runtime

DBOS durable runtime plugin for LlamaIndex Workflows.

Installation

pip install llama-agents-dbos

Usage

import asyncio
from llama_agents.dbos import DBOSRuntime
from dbos import DBOS, DBOSConfig
from workflows import Workflow, step, StartEvent, StopEvent

# Configure DBOS
config: DBOSConfig = {
    "name": "my-app",
    "system_database_url": "postgresql://...",
}
DBOS(config=config)

# Create runtime and workflow
runtime = DBOSRuntime()

class MyWorkflow(Workflow):
    @step
    async def my_step(self, ev: StartEvent) -> StopEvent:
        return StopEvent(result="done")

workflow = MyWorkflow(runtime=runtime)

# launch_sync() works outside async contexts; use await runtime.launch() inside one
runtime.launch_sync()

async def main():
    result = await workflow.run()

asyncio.run(main())

Features

• Durable workflow execution backed by DBOS
• Automatic step recording and replay
• Distributed workers and recovery support