fix: ensure Redis Tag version operator uses string values

bsbodden · bsbodden · commit 8e87eba937a3 · 2025-07-23T12:04:09.000-07:00
Convert version parameter to string for Redis Tag operator compatibility.
The Redis Tag operator requires string values for comparison operations.
diff --git a/langgraph/checkpoint/redis/__init__.py b/langgraph/checkpoint/redis/__init__.py
@@ -539,7 +539,7 @@ def get_channel_values(
                 filter_expression=(Tag("thread_id") == storage_safe_thread_id)
                 & (Tag("checkpoint_ns") == storage_safe_checkpoint_ns)
                 & (Tag("channel") == channel)
-                & (Tag("version") == version),
+                & (Tag("version") == str(version)),
                 return_fields=["type", "$.blob"],
                 num_results=1,
             )
diff --git a/langgraph/checkpoint/redis/aio.py b/langgraph/checkpoint/redis/aio.py
@@ -957,7 +957,7 @@ async def aget_channel_values(
                 filter_expression=(Tag("thread_id") == storage_safe_thread_id)
                 & (Tag("checkpoint_ns") == storage_safe_checkpoint_ns)
                 & (Tag("channel") == channel)
-                & (Tag("version") == version),
+                & (Tag("version") == str(version)),
                 return_fields=["type", "$.blob"],
                 num_results=1,
             )
diff --git a/langgraph/checkpoint/redis/ashallow.py b/langgraph/checkpoint/redis/ashallow.py
@@ -629,7 +629,7 @@ async def aget_channel_values(
                 filter_expression=(Tag("thread_id") == thread_id)
                 & (Tag("checkpoint_ns") == checkpoint_ns)
                 & (Tag("channel") == channel)
-                & (Tag("version") == version),
+                & (Tag("version") == str(version)),
                 return_fields=["type", "$.blob"],
                 num_results=1,
             )
diff --git a/langgraph/checkpoint/redis/shallow.py b/langgraph/checkpoint/redis/shallow.py
@@ -641,7 +641,7 @@ def get_channel_values(
                 filter_expression=(Tag("thread_id") == thread_id)
                 & (Tag("checkpoint_ns") == checkpoint_ns)
                 & (Tag("channel") == channel)
-                & (Tag("version") == version),
+                & (Tag("version") == str(version)),
                 return_fields=["type", "$.blob"],
                 num_results=1,
             )

Original file line number	Diff line number	Diff line change
`@@ -539,7 +539,7 @@ def get_channel_values(`
`539`	`539`	`filter_expression=(Tag("thread_id") == storage_safe_thread_id)`
`540`	`540`	`& (Tag("checkpoint_ns") == storage_safe_checkpoint_ns)`
`541`	`541`	`& (Tag("channel") == channel)`
`542`		`- & (Tag("version") == version),`
	`542`	`+ & (Tag("version") == str(version)),`
`543`	`543`	`return_fields=["type", "$.blob"],`
`544`	`544`	`num_results=1,`
`545`	`545`	`)`
Original file line number	Diff line number	Diff line change
`@@ -957,7 +957,7 @@ async def aget_channel_values(`
`957`	`957`	`filter_expression=(Tag("thread_id") == storage_safe_thread_id)`
`958`	`958`	`& (Tag("checkpoint_ns") == storage_safe_checkpoint_ns)`
`959`	`959`	`& (Tag("channel") == channel)`
`960`		`- & (Tag("version") == version),`
	`960`	`+ & (Tag("version") == str(version)),`
`961`	`961`	`return_fields=["type", "$.blob"],`
`962`	`962`	`num_results=1,`
`963`	`963`	`)`
Original file line number	Diff line number	Diff line change
`@@ -629,7 +629,7 @@ async def aget_channel_values(`
`629`	`629`	`filter_expression=(Tag("thread_id") == thread_id)`
`630`	`630`	`& (Tag("checkpoint_ns") == checkpoint_ns)`
`631`	`631`	`& (Tag("channel") == channel)`
`632`		`- & (Tag("version") == version),`
	`632`	`+ & (Tag("version") == str(version)),`
`633`	`633`	`return_fields=["type", "$.blob"],`
`634`	`634`	`num_results=1,`
`635`	`635`	`)`
Original file line number	Diff line number	Diff line change
`@@ -641,7 +641,7 @@ def get_channel_values(`
`641`	`641`	`filter_expression=(Tag("thread_id") == thread_id)`
`642`	`642`	`& (Tag("checkpoint_ns") == checkpoint_ns)`
`643`	`643`	`& (Tag("channel") == channel)`
`644`		`- & (Tag("version") == version),`
	`644`	`+ & (Tag("version") == str(version)),`
`645`	`645`	`return_fields=["type", "$.blob"],`
`646`	`646`	`num_results=1,`
`647`	`647`	`)`