WEBDIENSTE/langgraph
1
0
Fork 0
mirror of https://github.com/langchain-ai/langgraph.git synced 2026-08-24 16:42:24 +02:00
Code Issues Packages Projects Releases Wiki Activity

docs: fix redis pending_writes (#1842)

Browse Source
This commit is contained in:
Vadym Barda
2024-09-25 14:54:40 +00:00
committed by GitHub
parent 206420d4cc
commit 6136eb7471
1 changed files with 1 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
docs/docs/how-tos/persistence_redis.ipynb
+1 -9
View File
@@ -227,7 +227,7 @@
" (\n",
" task_id,\n",
" data[b\"channel\"].decode(),\n",
" serde.loads_typed((data[b\"type\"].decode(), data[b\"value\"].decode())),\n",
" serde.loads_typed((data[b\"type\"].decode(), data[b\"value\"])),\n",
" )\n",
" for (task_id, _), data in task_id_to_data.items()\n",
" ]\n",
@@ -639,14 +639,6 @@
" thread_id = config[\"configurable\"][\"thread_id\"]\n",
" checkpoint_id = get_checkpoint_id(config)\n",
" checkpoint_ns = config[\"configurable\"].get(\"checkpoint_ns\", \"\")\n",
" if not get_checkpoint_id(config):\n",
" config = {\n",
" \"configurable\": {\n",
" \"thread_id\": thread_id,\n",
" \"checkpoint_ns\": checkpoint_ns,\n",
" \"checkpoint_id\": checkpoint_id,\n",
" }\n",
" }\n",
"\n",
" checkpoint_key = await self._aget_checkpoint_key(\n",
" self.conn, thread_id, checkpoint_ns, checkpoint_id\n",