Update langgraph/checkpoint/redis/__init__.py

bsbodden · Copilot · web-flow · commit 5430647cb0cb · 2025-05-29T13:39:15.000+02:00
Co-authored-by: Copilot &lt;175728472+Copilot@users.noreply.github.com&gt;
diff --git a/langgraph/checkpoint/redis/__init__.py b/langgraph/checkpoint/redis/__init__.py
@@ -360,7 +360,7 @@ def get_tuple(self, config: RunnableConfig) -> Optional[CheckpointTuple]:
                     Tag("thread_id") == to_storage_safe_id(doc_thread_id)
                 )
                 & (Tag("checkpoint_ns") == to_storage_safe_str(doc_checkpoint_ns)),
-                return_fields=["key"],  # Assuming the key field exists in the index
+                return_fields=["key", "channel", "version"],  # Ensure channel and version are available
                 num_results=1000,
             )
             blob_results = self.checkpoint_blobs_index.search(blob_query)

Original file line number	Diff line number	Diff line change
`@@ -360,7 +360,7 @@ def get_tuple(self, config: RunnableConfig) -> Optional[CheckpointTuple]:`
`360`	`360`	`Tag("thread_id") == to_storage_safe_id(doc_thread_id)`
`361`	`361`	`)`
`362`	`362`	`& (Tag("checkpoint_ns") == to_storage_safe_str(doc_checkpoint_ns)),`
`363`		`- return_fields=["key"], # Assuming the key field exists in the index`
	`363`	`+ return_fields=["key", "channel", "version"], # Ensure channel and version are available`
`364`	`364`	`num_results=1000,`
`365`	`365`	`)`
`366`	`366`	`blob_results = self.checkpoint_blobs_index.search(blob_query)`