From 093af1a89309ca07ad4993b57afe3cafe0750bde Mon Sep 17 00:00:00 2001 From: jacoblee93 Date: Thu, 19 Sep 2024 15:07:30 -0700 Subject: [PATCH 1/2] Use imported constant for namespace end --- libs/langgraph/langgraph/pregel/algo.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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, From ec1f4256323384b437144ff32f6e106f31a4480f Mon Sep 17 00:00:00 2001 From: Jacob Lee Date: Thu, 19 Sep 2024 15:53:50 -0700 Subject: [PATCH 2/2] Update algo.py --- libs/langgraph/langgraph/pregel/algo.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libs/langgraph/langgraph/pregel/algo.py b/libs/langgraph/langgraph/pregel/algo.py index 0084034a5..940edbada 100644 --- a/libs/langgraph/langgraph/pregel/algo.py +++ b/libs/langgraph/langgraph/pregel/algo.py @@ -29,8 +29,8 @@ from langgraph.constants import ( CONFIG_KEY_TASK_ID, INTERRUPT, NO_WRITES, - NS_SEP, NS_END, + NS_SEP, PULL, PUSH, RESERVED,