mirror of
https://github.com/langchain-ai/langgraph.git
synced 2026-08-25 17:12:26 +02:00
Sydney RunkleandGitHub
8c4e698c5a
* public interfaces for channels * public interfaces for func * public interfaces for graph * pi for managed * first pass public interface for top level modules * first pass at private for utils -> _internal * private interface for pregel * scratchpad/stream protocol move * docs update * backwards compat for runnable * deprecation warning for send and interrupt * deprecation for pregel import
49 lines
1.3 KiB
Python
49 lines
1.3 KiB
Python
"""Create a sequential no-op graph consisting of a few hundred nodes."""
|
|
|
|
from langgraph._internal._runnable import RunnableCallable
|
|
from langgraph.graph import MessagesState, StateGraph
|
|
|
|
|
|
def create_sequential(number_nodes: int) -> StateGraph:
|
|
"""Create a sequential no-op graph consisting of a few hundred nodes."""
|
|
builder = StateGraph(MessagesState)
|
|
|
|
def noop(state: MessagesState) -> None:
|
|
"""No-op function."""
|
|
pass
|
|
|
|
async def anoop(state: MessagesState) -> None:
|
|
"""No-op function."""
|
|
pass
|
|
|
|
prev_node = "__start__"
|
|
|
|
for i in range(number_nodes):
|
|
name = f"node_{i}"
|
|
builder.add_node(name, RunnableCallable(noop, anoop))
|
|
builder.add_edge(prev_node, name)
|
|
prev_node = name
|
|
|
|
builder.add_edge(prev_node, "__end__")
|
|
return builder
|
|
|
|
|
|
if __name__ == "__main__":
|
|
import asyncio
|
|
import time
|
|
|
|
import uvloop
|
|
|
|
graph = create_sequential(3000).compile()
|
|
input = {"messages": []} # Empty list of messages
|
|
config = {"recursion_limit": 20000000000}
|
|
|
|
async def run():
|
|
len([c async for c in graph.astream(input, config=config)])
|
|
|
|
uvloop.install()
|
|
start = time.time()
|
|
asyncio.run(run())
|
|
end = time.time()
|
|
print(f"Time taken: {end - start:.4f} seconds")
|