fix(shallow): encode blob bytes in shallow implementations

bsbodden · bsbodden · commit 84d9f8b960ae · 2025-11-16T22:22:39.000-07:00
- Add _encode_blob() in ShallowRedisSaver.put_writes()
- Add _encode_blob() in AsyncShallowRedisSaver.aput_writes()
- Completes blob encoding fix across ALL implementations (regular and shallow)
diff --git a/langgraph/checkpoint/redis/ashallow.py b/langgraph/checkpoint/redis/ashallow.py
@@ -534,7 +534,7 @@ async def aput_writes(
                     "idx": WRITES_IDX_MAP.get(channel, idx),
                     "channel": channel,
                     "type": type_,
-                    "blob": blob,
+                    "blob": self._encode_blob(blob),  # Encode bytes to base64 string for Redis
                 }
                 writes_objects.append(write_obj)
 
diff --git a/langgraph/checkpoint/redis/shallow.py b/langgraph/checkpoint/redis/shallow.py
@@ -529,7 +529,7 @@ def put_writes(
                 "idx": WRITES_IDX_MAP.get(channel, idx),
                 "channel": channel,
                 "type": type_,
-                "blob": blob,
+                "blob": self._encode_blob(blob),  # Encode bytes to base64 string for Redis
             }
             writes_objects.append(write_obj)
 

Original file line number	Diff line number	Diff line change
`@@ -534,7 +534,7 @@ async def aput_writes(`
`534`	`534`	`"idx": WRITES_IDX_MAP.get(channel, idx),`
`535`	`535`	`"channel": channel,`
`536`	`536`	`"type": type_,`
`537`		`- "blob": blob,`
	`537`	`+ "blob": self._encode_blob(blob), # Encode bytes to base64 string for Redis`
`538`	`538`	`}`
`539`	`539`	`writes_objects.append(write_obj)`
`540`	`540`
Original file line number	Diff line number	Diff line change
`@@ -529,7 +529,7 @@ def put_writes(`
`529`	`529`	`"idx": WRITES_IDX_MAP.get(channel, idx),`
`530`	`530`	`"channel": channel,`
`531`	`531`	`"type": type_,`
`532`		`- "blob": blob,`
	`532`	`+ "blob": self._encode_blob(blob), # Encode bytes to base64 string for Redis`
`533`	`533`	`}`
`534`	`534`	`writes_objects.append(write_obj)`
`535`	`535`