diff --git a/langgraph/channels/ephemeral_value.py b/langgraph/channels/ephemeral_value.py index b880f9f2f..17a11f552 100644 --- a/langgraph/channels/ephemeral_value.py +++ b/langgraph/channels/ephemeral_value.py @@ -54,7 +54,9 @@ class EphemeralValue(Generic[Value], BaseChannel[Value, Value, Value]): finally: return if len(values) != 1 and self.guard: - raise InvalidUpdateError("LastValue can only receive one value per step.") + raise InvalidUpdateError( + "EphemeralValue can only receive one value per step." + ) self.value = values[-1] diff --git a/langgraph/checkpoint/aiosqlite.py b/langgraph/checkpoint/aiosqlite.py index 0159645c2..1e9734e7a 100644 --- a/langgraph/checkpoint/aiosqlite.py +++ b/langgraph/checkpoint/aiosqlite.py @@ -191,6 +191,7 @@ class AsyncSqliteSaver(BaseCheckpointSaver, AbstractAsyncContextManager): await self.conn async with self.conn.executescript( """ + PRAGMA journal_mode=WAL; CREATE TABLE IF NOT EXISTS checkpoints ( thread_id TEXT NOT NULL, thread_ts TEXT NOT NULL, diff --git a/langgraph/checkpoint/sqlite.py b/langgraph/checkpoint/sqlite.py index f72a6f58f..23da9a7df 100644 --- a/langgraph/checkpoint/sqlite.py +++ b/langgraph/checkpoint/sqlite.py @@ -159,6 +159,7 @@ class SqliteSaver(BaseCheckpointSaver, AbstractContextManager): self.conn.executescript( """ + PRAGMA journal_mode=WAL; CREATE TABLE IF NOT EXISTS checkpoints ( thread_id TEXT NOT NULL, thread_ts TEXT NOT NULL,