Skip to content

Commit 023f629

Browse files
committed
Name indexes using custom prefix
1 parent e9f9e17 commit 023f629

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

langgraph/checkpoint/redis/base.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ def checkpoints_schema(self) -> Dict[str, Any]:
103103
"""Schema for the checkpoints index."""
104104
return {
105105
"index": {
106-
"name": "checkpoints",
106+
"name": self._checkpoint_prefix,
107107
"prefix": self._checkpoint_prefix + REDIS_KEY_SEPARATOR,
108108
"storage_type": "json",
109109
},
@@ -124,7 +124,7 @@ def blobs_schema(self) -> Dict[str, Any]:
124124
"""Schema for the checkpoint blobs index."""
125125
return {
126126
"index": {
127-
"name": "checkpoints_blobs",
127+
"name": self._checkpoint_blob_prefix,
128128
"prefix": self._checkpoint_blob_prefix + REDIS_KEY_SEPARATOR,
129129
"storage_type": "json",
130130
},
@@ -143,7 +143,7 @@ def writes_schema(self) -> Dict[str, Any]:
143143
"""Schema for the checkpoint writes index."""
144144
return {
145145
"index": {
146-
"name": "checkpoint_writes",
146+
"name": self._checkpoint_write_prefix,
147147
"prefix": self._checkpoint_write_prefix + REDIS_KEY_SEPARATOR,
148148
"storage_type": "json",
149149
},

0 commit comments

Comments
 (0)