Update aio.py

aarongrtech · web-flow · commit 8fc750bc07c2 · 2025-08-14T21:32:32.000-05:00
Async message deserialization fix
diff --git a/langgraph/checkpoint/redis/aio.py b/langgraph/checkpoint/redis/aio.py
@@ -709,7 +709,7 @@ async def alist(
                     if isinstance(checkpoint_data, dict)
                     else orjson.loads(checkpoint_data)
                 )
-                channel_values = checkpoint_dict.get("channel_values", {})
+                channel_values = self._recursive_deserialize(checkpoint_dict.get("channel_values", {}))
             else:
                 # If checkpoint data is missing, the document is corrupted
                 # Set empty channel values rather than attempting a fallback

Original file line number	Diff line number	Diff line change
`@@ -709,7 +709,7 @@ async def alist(`
`709`	`709`	`if isinstance(checkpoint_data, dict)`
`710`	`710`	`else orjson.loads(checkpoint_data)`
`711`	`711`	`)`
`712`		`- channel_values = checkpoint_dict.get("channel_values", {})`
	`712`	`+ channel_values = self._recursive_deserialize(checkpoint_dict.get("channel_values", {}))`
`713`	`713`	`else:`
`714`	`714`	`# If checkpoint data is missing, the document is corrupted`
`715`	`715`	`# Set empty channel values rather than attempting a fallback`