A wrapper for LangGraph agents that handles observability, memory, and guardrails
Project description
graph-abstract
A local-first Python library that provides zero-config PostgreSQL checkpointing and telemetry logging for LangGraph agents simply by replacing your standard StateGraph import.
Installation
Core Observability and Checkpointing
To install the core package with database checkpointing and telemetry logging:
pip install graph-abstract
With Optional UI Console
To install the package along with the Streamlit-based visualization console:
pip install "graph-abstract[ui]"
Quick Start
Replace your standard LangGraph StateGraph import with graph_abstract:
from typing import Dict, Any
from typing_extensions import TypedDict
from graph_abstract import StateGraph
class AgentState(TypedDict):
messages: list[str]
def my_node(state: AgentState) -> Dict[str, Any]:
return {"messages": ["hello"]}
db_uri = "postgresql://postgres:postgres@localhost:5432/my_database"
graph = StateGraph(AgentState, db_uri=db_uri)
graph.add_node("my_node", my_node)
graph.set_entry_point("my_node")
graph.set_finish_point("my_node")
compiled = graph.compile()
When you call compiled.ainvoke, the library dynamically setups Postgres checkpoint tables and logs execution traces (chains, tools, and LLMs) into the database under the configured thread_id.
Observability UI Console
If you installed graph-abstract with the ui extra, you can launch the console to inspect threads, visualize trace events, and view state checkpoints.
Run the console via python:
python -m graph_abstract --db-uri postgresql://postgres:postgres@localhost:5432/my_database
Or run the command line executable:
graph-abstract-ui --db-uri postgresql://postgres:postgres@localhost:5432/my_database
Custom Guardrails
graph-abstract provides custom inbound and outbound safety guardrails. Evaluations for prompt injection, content safety, and hallucination are performed using LangChain's native structured output bindings for Ollama and OpenAI. Local regex-based PII redaction runs locally with zero LLM costs.
Quick Example
from typing_extensions import TypedDict
from graph_abstract import StateGraph, GuardrailConfig, GuardrailProvider
class AgentState(TypedDict):
messages: list[str]
context: str
safety_config = GuardrailConfig(
inbound_provider=GuardrailProvider.OLLAMA,
safety_model="llama3.1:8b",
check_prompt_injection=True,
outbound_provider=GuardrailProvider.OLLAMA,
eval_model="llama3.1:8b",
check_hallucination=True,
redact_pii=True,
fallback_message="I cannot answer that, please try to rephrase your question."
)
workflow = StateGraph(
AgentState,
db_uri="postgresql://postgres:postgres@localhost:5432/my_database",
guardrails=safety_config
)
Node-Specific Guardrails
To apply guardrails to specific nodes only, pass a dictionary mapping node names to GuardrailConfig objects:
workflow = StateGraph(
AgentState,
db_uri="postgresql://postgres:postgres@localhost:5432/my_database",
guardrails={
"Trader": GuardrailConfig(
outbound_provider=GuardrailProvider.OLLAMA,
eval_model="llama3.1:8b",
check_hallucination=True
)
}
)
Config Options
| Parameter | Type | Default | Description |
|---|---|---|---|
inbound_provider |
GuardrailProvider |
None |
Provider for inbound validation (OLLAMA or OPENAI). |
safety_model |
str |
None |
Model name to use for inbound safety/prompt injection checks. |
check_prompt_injection |
bool |
False |
Enable inbound prompt injection and jailbreak detection. |
outbound_provider |
GuardrailProvider |
None |
Provider for outbound validation (OLLAMA or OPENAI). |
eval_model |
str |
None |
Model name to use for outbound hallucination or safety checks. |
check_hallucination |
bool |
False |
Enable outbound hallucination check comparing node outputs to graph context. |
redact_pii |
bool |
False |
Enable local regex-based redaction of emails, credit cards, SSNs, and phone numbers. |
fallback_message |
Optional[str] |
"I cannot answer..." |
The message returned when a guardrail is tripped. Set to None to raise a GuardrailValidationError instead. |
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file graph_abstract-0.1.3.tar.gz.
File metadata
- Download URL: graph_abstract-0.1.3.tar.gz
- Upload date:
- Size: 14.5 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/6.2.0 CPython/3.12.0
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
b7f3edbc00993885a8ff5967ff42b720d7ed3115d3e1332d7460b6dd25763c98
|
|
| MD5 |
d13556f68d43dd949ef945a3b48ca8c7
|
|
| BLAKE2b-256 |
8e2e00304add437cd103b8f38d5282dc50d38662da04595a8c1d056d562d3276
|
File details
Details for the file graph_abstract-0.1.3-py3-none-any.whl.
File metadata
- Download URL: graph_abstract-0.1.3-py3-none-any.whl
- Upload date:
- Size: 12.9 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/6.2.0 CPython/3.12.0
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
078a084717152b8f099bf577875c0af0c40ed8784b63d020b37ba290662759c5
|
|
| MD5 |
93e4987894b157b4f880abf898bd5cd3
|
|
| BLAKE2b-256 |
148d53644a9002d8f975ec3dd75519c1e01f2bd7ffaae9d732de0b213273ee06
|