Skip to content

Commit e1875e8

Browse files
committed
Update version to 1.0.2 and refactor serialization in AsyncCouchbaseSaver and CouchbaseSaver to streamline binary encoding process.
1 parent 4ce7848 commit e1875e8

File tree

3 files changed

+6
-5
lines changed

3 files changed

+6
-5
lines changed

langgraph_checkpointer_couchbase/async_cb_saver.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -331,8 +331,9 @@ async def aput_writes(
331331
for idx, (channel, value) in enumerate(writes):
332332
upsert_key = f"{thread_id}::{checkpoint_ns}::{checkpoint_id}::{task_id}::{idx}"
333333
type_, serialized_value = self.serde.dumps_typed(value)
334-
if serialized_value:
335-
serialized_value = _encode_binary(serialized_value)
334+
335+
serialized_value = _encode_binary(serialized_value)
336+
336337
doc = {
337338
"thread_id": thread_id,
338339
"checkpoint_ns": checkpoint_ns,

langgraph_checkpointer_couchbase/couchbase_saver.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -374,8 +374,8 @@ def put_writes(
374374
type_, serialized_value = self.serde.dumps_typed(value)
375375

376376
# Encode the serialized value to base64 string
377-
if serialized_value:
378-
serialized_value = _encode_binary(serialized_value)
377+
378+
serialized_value = _encode_binary(serialized_value)
379379

380380
doc = {
381381
"thread_id": thread_id,

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
44

55
[project]
66
name = "langgraph-checkpointer-couchbase"
7-
version = "1.0.1"
7+
version = "1.0.2"
88
description = ''
99
readme = "README.md"
1010
requires-python = ">=3.8"

0 commit comments

Comments
 (0)