diff --git a/libs/langgraph/langgraph/pregel/algo.py b/libs/langgraph/langgraph/pregel/algo.py index c2c5866e4..0084034a5 100644 --- a/libs/langgraph/langgraph/pregel/algo.py +++ b/libs/langgraph/langgraph/pregel/algo.py @@ -30,6 +30,7 @@ from langgraph.constants import ( INTERRUPT, NO_WRITES, NS_SEP, + NS_END, PULL, PUSH, RESERVED, @@ -471,7 +472,7 @@ def prepare_single_task( PULL, *triggers, ) - task_checkpoint_ns = f"{checkpoint_ns}:{task_id}" + task_checkpoint_ns = f"{checkpoint_ns}{NS_END}{task_id}" metadata = { "langgraph_step": step, "langgraph_node": name,