From 9bf3fc2d0fa9c67e1a2725fa9f8012cd31146c11 Mon Sep 17 00:00:00 2001
From: Vadym Barda <vadym@langchain.dev>
Date: Mon, 10 Mar 2025 11:14:20 -0400
Subject: [PATCH] checkpoint-sqlite: commit transactions in
 AsyncSqliteSaver.aput_writes (#3762)

---
 libs/checkpoint-sqlite/langgraph/checkpoint/sqlite/aio.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/libs/checkpoint-sqlite/langgraph/checkpoint/sqlite/aio.py b/libs/checkpoint-sqlite/langgraph/checkpoint/sqlite/aio.py
index befa6cfbe..91097c9b8 100644
--- a/libs/checkpoint-sqlite/langgraph/checkpoint/sqlite/aio.py
+++ b/libs/checkpoint-sqlite/langgraph/checkpoint/sqlite/aio.py
@@ -530,6 +530,7 @@ class AsyncSqliteSaver(BaseCheckpointSaver[str]):
                     for idx, (channel, value) in enumerate(writes)
                 ],
             )
+            await self.conn.commit()
 
     def get_next_version(self, current: Optional[str], channel: ChannelProtocol) -> str:
         """Generate the next version ID for a channel.