Skip to content

Commit 6ea6810

Browse files
authored
Fixes asynchronous message deserialization
1 parent 36b503a commit 6ea6810

File tree

1 file changed

+2
-2
lines changed
  • langgraph/checkpoint/redis

1 file changed

+2
-2
lines changed

langgraph/checkpoint/redis/aio.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -540,13 +540,13 @@ async def aget_tuple(self, config: RunnableConfig) -> Optional[CheckpointTuple]:
540540
# Execute all tasks in parallel - pending_sends is optional
541541
if doc_parent_checkpoint_id:
542542
results = await asyncio.gather(*tasks)
543-
channel_values: Dict[str, Any] = results[0]
543+
channel_values: Dict[str, Any] = self._recursive_deserialize(results[0])
544544
pending_sends: List[Tuple[str, Union[str, bytes]]] = results[1]
545545
pending_writes: List[PendingWrite] = results[2]
546546
else:
547547
# Only channel_values and pending_writes tasks
548548
results = await asyncio.gather(*tasks)
549-
channel_values = results[0]
549+
channel_values = self._recursive_deserialize(results[0])
550550
pending_sends = []
551551
pending_writes = results[1]
552552

0 commit comments

Comments
 (0)