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",