We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 145a43f commit a097b4eCopy full SHA for a097b4e
dive_mcp_host/host/helpers/checkpointer.py
@@ -1,4 +1,5 @@
1
from contextlib import AbstractAsyncContextManager
2
+from urllib.parse import unquote
3
4
from langgraph.checkpoint.postgres.aio import AsyncPostgresSaver
5
from langgraph.checkpoint.sqlite.aio import AsyncSqliteSaver
@@ -22,7 +23,7 @@ def get_checkpointer(
22
23
"""
24
if uri.startswith("sqlite"):
25
path = uri.removeprefix("sqlite:///")
- return AsyncSqliteSaver.from_conn_string(path)
26
+ return AsyncSqliteSaver.from_conn_string(unquote(path))
27
if uri.startswith("postgres"):
28
return AsyncPostgresSaver.from_conn_string(uri)
29
raise ValueError(f"Unsupported database: {uri}")
0 commit comments