From 6136eb74718b5b6a799a16ca1f3ba64e2dee672e Mon Sep 17 00:00:00 2001 From: Vadym Barda Date: Wed, 25 Sep 2024 10:54:40 -0400 Subject: [PATCH] docs: fix redis pending_writes (#1842) --- docs/docs/how-tos/persistence_redis.ipynb | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/docs/docs/how-tos/persistence_redis.ipynb b/docs/docs/how-tos/persistence_redis.ipynb index 78eda5f43..a3c5ec33c 100644 --- a/docs/docs/how-tos/persistence_redis.ipynb +++ b/docs/docs/how-tos/persistence_redis.ipynb @@ -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",