langgraph_sdk_client_thread_creation_and_run_streaming.py

1import asyncio
2from langgraph_sdk import get_client
3
4async def main():
5    # 1. Initialize the client
6    # By default it uses http://localhost:8123 (the default for local LangGraph server)
7    client = get_client(url="http://localhost:8123")
8
9    # 2. List available assistants
10    assistants = await client.assistants.search()
11    if not assistants:
12        print("No assistants found. Make sure your LangGraph server is running.")
13        return
14    
15    assistant = assistants[0]
16    assistant_id = assistant["assistant_id"]
17
18    # 3. Create a new thread
19    thread = await client.threads.create()
20
21    # 4. Stream a run
22    input_data = {"messages": [{"role": "user", "content": "Hello! How are you?"}]}
23    
24    async for chunk in client.runs.stream(
25        thread["thread_id"],
26        assistant_id,
27        input=input_data,
28    ):
29        print(f"Receiving len: {len(chunk.data)}")
30        print(chunk)
31
32if __name__ == "__main__":
33    asyncio.run(main())