WEBDIENSTE/langgraph
1
0
Fork 0
mirror of https://github.com/langchain-ai/langgraph.git synced 2026-09-10 11:47:51 +02:00
Code Issues Packages Projects Releases Wiki Activity

Tests?

Browse Source
This commit is contained in:
Tat Dat Duong
2024-10-08 20:55:49 +02:00
parent 45a12c938b
commit 7a282f82dc
1 changed files with 13 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libs/langgraph/tests/test_pregel_async.py
+13 -9
View File
@@ -9944,15 +9944,19 @@ async def test_debug_nested_subgraphs():
(AnyStr("gp_two:"), AnyStr("p_two:")),
]
history_ns = {
ns: [
c
async for c in graph.aget_state_history(
{"configurable": {"thread_id": "1", "checkpoint_ns": "|".join(ns)}}
)
][::-1]
for ns in stream_ns.keys()
}
history_ns = {}
for ns in stream_ns.keys():
async def get_history():
history = [
c
async for c in graph.aget_state_history(
{"configurable": {"thread_id": "1", "checkpoint_ns": "|".join(ns)}}
)
]
return history[::-1]
history_ns[ns] = await get_history()
def normalize_config(config: Optional[dict]) -> Optional[dict]:
if config is None: