durable.lifecycle

DBOS lifecycle management for agent-runtimes.

Handles DBOS database initialization, launch, health checking, recovery of pending workflows, and graceful shutdown.

DurableLifecycle Objects

class DurableLifecycle()

Manages the DBOS lifecycle within the agent-runtimes process.

Typical usage inside the FastAPI lifespan::

lifecycle = DurableLifecycle(config)
await lifecycle.launch()   # On startup
...
await lifecycle.shutdown() # On shutdown

config : DurableConfig Configuration for the DBOS backend.

async def launch() -> None

Initialize and launch DBOS.

Creates the database directory (for SQLite), calls DBOS.launch(), and optionally triggers recovery of pending workflows.

async def shutdown() -> None

Gracefully shut down DBOS.

Flushes any pending state and closes database connections.

def is_healthy() -> bool

Check if DBOS is running and healthy.

bool True if DBOS was launched and is available.

async def prepare_checkpoint() -> dict

Prepare for a CRIU checkpoint by flushing DBOS state.

Called by the companion's /v1/prepare-checkpoint endpoint before the container is frozen.

dict Metadata about the DBOS state at checkpoint time.

async def post_restore() -> None

Re-initialize after a CRIU restore.

Called by the companion's /v1/post-restore endpoint after the container is unfrozen. Re-establishes database connections.