checkpoint-sqlite: commit transactions in AsyncSqliteSaver.aput_writes (#3762)

This commit is contained in:
Vadym Barda
2025-03-10 15:14:20 +00:00
committed by GitHub
parent d4368cfa97
commit 9bf3fc2d0f
@@ -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.