Error when using mcp tools in a state graph

[SaiSanthosh1508]

from langchain_mcp_adapters.tools import load_mcp_tools
from langchain_mcp_adapters.client import MultiServerMCPClient
from langgraph.prebuilt import create_react_agent
from langchain_core.prompts import PromptTemplate
from langgraph.graph import StateGraph, MessagesState, START,END
from langgraph.prebuilt import tools_condition, ToolNode
from langgraph.checkpoint.memory import InMemorySaver
from typing import Literal
import asyncio
from langchain_core.messages import HumanMessage

client = MultiServerMCPClient(
    {
        "file-system" : {
            "command" : "python",
            "args" : ["C:\\Users\\santh\\OneDrive\\Documents\\langchain\\custom-servers\\file-system.py"],
            "transport" : "stdio"
        },
        "context7": {
            "command": "npx",
            "args": ["-y", "@upstash/context7-mcp@latest"],
            "transport": "stdio",
        },
    }
)

prompt = PromptTemplate.from_file("prompt.txt", encoding="utf-8")

async def main():
    async with client.session("file-system") as session_fs, client.session("context7") as session_context7:
        # Load tools from the MCP server
        tools = []
        tools += await load_mcp_tools(session_context7)
        tools += await load_mcp_tools(session_fs)

        agent = create_react_agent(
            model = "google_genai:gemini-2.5-flash-preview-05-20",
            tools = tools,
            debug=True,
            prompt=prompt,
        )

        tools_node = ToolNode(tools)
        def llm_call(state : MessagesState):
            response = agent.invoke(state['messages'])
            return {"messages": response}
        
        def get_human_input(state : MessagesState):
            
            value = input("Please provide your input: ")
            if value == "complete":
                return {"messages" : state}
            else:
                return {"messages": state["messages"] + [{"role": "user", "content": value}]}

        def route_decision(state : MessagesState) -> Literal["tools", "human_input"]:
            last_msg = state["messages"][-1]
            if hasattr(last_msg,"tool_calls") and last_msg.tool_calls:
                return "tools"
            else:
                return "human_input"

        def human_route_decision(state : MessagesState):
            value = input("Any improvements? if no type 'done' to finish, or enter the next input: ")
            if value == "done":
                return "done"
            else:
                state["messages"].append(HumanMessage(content=value))
                return "continue"
            
        ## Build the graph
        builder = StateGraph(MessagesState)
        builder.add_node("llm_call",llm_call)
        builder.add_node("get_human_input",get_human_input)
        builder.add_node("tools_node", tools_node)

        builder.add_edge(START, "llm_call")
        builder.add_conditional_edges(
            "llm_call",
            route_decision,
            {
                "tools": "tools_node",
                "human_input": "get_human_input"
            }
        )
        builder.add_edge("tools_node", "llm_call")
        # builder.add_edge("get_human_input", "llm_call")
        builder.add_conditional_edges(
            "get_human_input",
            human_route_decision,
            {
                "done": END,
                "continue": "llm_call"
            }
        )
        
        config = {"configurable": {"thread_id": 1}, "recursion_limit": 200}
        checkpointer = InMemorySaver()
        graph = builder.compile(checkpointer=checkpointer)

        k = graph.get_graph().draw_mermaid_png()
        with open('saved_image.png', 'wb') as f:
            f.write(k)

        response = await graph.ainvoke({
            "messages": (
"""
I want to create a homepage for a futuristic AI robot called AstraBot that helps people with daily tasks like scheduling, home automation, and reminders. The website should have a very clean and modern look, with a sleek design that feels advanced but easy to understand.

The homepage should include:

1. A large, eye-catching top section with the robot’s name, a short catchy slogan, a button that encourages people to learn more, and a high-quality image of a robot in action.
2. A section that explains three key features of AstraBot with short descriptions and icons or visuals to go with each.
3. Testimonials from two happy users, with their names, photos, and a short sentence about how AstraBot helped them.
4. A final section with a strong call to action inviting visitors to get started or make a purchase.
5. A footer with some basic links like "About", "Privacy Policy", "Support", and some small icons linking to social media.

The whole page should feel like it belongs to a next-generation tech product — sleek, professional, and easy to read. Use elegant colors and smooth layout. Make sure it works well on both computers and phones.

All the content and files should be organized inside a folder called `astrabot_site`.

"""
            )
        },config=config)

        print(response)


if __name__ == "__main__":
    asyncio.run(main())

The graph is provided below:

The below is the errror message i recieved

(langchain) PS C:\Users\santh\OneDrive\Documents\langchain\web-agent> python checks.py
[-1:checkpoint] State at the end of step -1:
{'messages': []}
[0:tasks] Starting 1 task for step 0:
- __start__ -> [HumanMessage(content='\nI want to create a homepage for a futuristic AI robot called AstraBot that helps people with daily tasks like scheduling, home automation, and reminders. The website should have a very clean and modern look, with a sleek design that feels advanced but easy to understand.\n\nThe homepage should include:\n\n1. A large, eye-catching top section with the robot’s name, a short catchy slogan, a button that encourages people to learn more, and a high-quality image of a robot in action.\n2. A section that explains three key features of AstraBot with short descriptions and icons or visuals to go with each.\n3. Testimonials from two happy users, with their names, photos, and a short sentence about how AstraBot helped them.\n4. A final section with a strong call to action inviting visitors to get started or make a purchase.\n5. A footer with some basic links like "About", "Privacy Policy", "Support", and some small icons linking to social media.\n\nThe whole page should feel like it belongs to a next-generation tech product — sleek, professional, and easy to read. Use elegant colors and smooth layout. Make sure it works well on both computers and phones.\n\nAll the content and files should be organized inside a folder called `astrabot_site`.\n\n', additional_kwargs={}, response_metadata={}, id='68ad7178-2917-4c5e-84bc-9bd1654ef7e2')]
  + Exception Group Traceback (most recent call last):
  |   File "C:\Users\santh\OneDrive\Documents\langchain\web-agent\checks.py", line 130, in <module>
  |     asyncio.run(main())
  |     ~~~~~~~~~~~^^^^^^^^
  |   File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\asyncio\runners.py", line 195, in run
  |     return runner.run(main)
  |            ~~~~~~~~~~^^^^^^
  |   File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\asyncio\runners.py", line 118, in run
  |     return self._loop.run_until_complete(task)
  |            ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~^^^^^^
  |   File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\asyncio\base_events.py", line 719, in run_until_complete
  |     return future.result()
  |            ~~~~~~~~~~~~~^^
  |   File "C:\Users\santh\OneDrive\Documents\langchain\web-agent\checks.py", line 30, in main
  |     async with client.session("file-system") as session_fs, client.session("context7") as session_context7:
  |                ~~~~~~~~~~~~~~^^^^^^^^^^^^^^^
  |   File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\contextlib.py", line 235, in __aexit__
  |     await self.gen.athrow(value)
  |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\client.py", line 106, in session
  |     async with create_session(self.connections[server_name]) as session:
  |                ~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  |   File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\contextlib.py", line 235, in __aexit__
  |     await self.gen.athrow(value)
  |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\sessions.py", line 280, in create_session
  |     async with _create_stdio_session(
  |                ~~~~~~~~~~~~~~~~~~~~~^
  |         command=connection["command"],
  |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  |     ...<7 lines>...
  |         session_kwargs=connection.get("session_kwargs"),
  |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  |     ) as session:
  |     ^
  |   File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\contextlib.py", line 235, in __aexit__
  |     await self.gen.athrow(value)
  |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\sessions.py", line 148, in _create_stdio_session
  |     async with stdio_client(server_params) as (read, write):
  |                ~~~~~~~~~~~~^^^^^^^^^^^^^^^
  |   File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\contextlib.py", line 235, in __aexit__
  |     await self.gen.athrow(value)
  |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\mcp\client\stdio\__init__.py", line 171, in stdio_client
  |     anyio.create_task_group() as tg,
  |     ~~~~~~~~~~~~~~~~~~~~~~~^^
  |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\anyio\_backends\_asyncio.py", line 772, in __aexit__
  |     raise BaseExceptionGroup(
  |         "unhandled errors in a TaskGroup", self._exceptions
  |     ) from None
  | ExceptionGroup: unhandled errors in a TaskGroup (1 sub-exception)
  +-+---------------- 1 ----------------
    | Exception Group Traceback (most recent call last):
    |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\mcp\client\stdio\__init__.py", line 177, in stdio_client
    |     yield read_stream, write_stream
    |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\sessions.py", line 149, in _create_stdio_session
    |     async with ClientSession(read, write, **(session_kwargs or {})) as session:       
    |                ~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\mcp\shared\session.py", line 220, in __aexit__
    |     return await self._task_group.__aexit__(exc_type, exc_val, exc_tb)
    |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\anyio\_backends\_asyncio.py", line 772, in __aexit__
    |     raise BaseExceptionGroup(
    |         "unhandled errors in a TaskGroup", self._exceptions
    |     ) from None
    | ExceptionGroup: unhandled errors in a TaskGroup (1 sub-exception)
    +-+---------------- 1 ----------------
      | Exception Group Traceback (most recent call last):
      |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\sessions.py", line 150, in _create_stdio_session
      |     yield session
      |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\sessions.py", line 291, in create_session
      |     yield session
      |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\client.py", line 109, in session
      |     yield session
      |   File "C:\Users\santh\OneDrive\Documents\langchain\web-agent\checks.py", line 30, in main
      |     async with client.session("file-system") as session_fs, client.session("context7") as session_context7:
      |                                                             ~~~~~~~~~~~~~~^^^^^^^^^^^^
      |   File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\contextlib.py", line 235, in __aexit__
      |     await self.gen.athrow(value)
      |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\client.py", line 106, in session
      |     async with create_session(self.connections[server_name]) as session:
      |                ~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
      |   File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\contextlib.py", line 235, in __aexit__
      |     await self.gen.athrow(value)
      |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\sessions.py", line 280, in create_session
      |     async with _create_stdio_session(
      |                ~~~~~~~~~~~~~~~~~~~~~^
      |         command=connection["command"],
      |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
      |     ...<7 lines>...
      |         session_kwargs=connection.get("session_kwargs"),
      |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
      |     ) as session:
      |     ^
      |   File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\contextlib.py", line 235, in __aexit__
      |     await self.gen.athrow(value)
      |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\sessions.py", line 148, in _create_stdio_session
      |     async with stdio_client(server_params) as (read, write):
      |                ~~~~~~~~~~~~^^^^^^^^^^^^^^^
      |   File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\contextlib.py", line 235, in __aexit__
      |     await self.gen.athrow(value)
      |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\mcp\client\stdio\__init__.py", line 171, in stdio_client
      |     anyio.create_task_group() as tg,
      |     ~~~~~~~~~~~~~~~~~~~~~~~^^
      |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\anyio\_backends\_asyncio.py", line 772, in __aexit__
      |     raise BaseExceptionGroup(
      |         "unhandled errors in a TaskGroup", self._exceptions
      |     ) from None
      | ExceptionGroup: unhandled errors in a TaskGroup (1 sub-exception)
      +-+---------------- 1 ----------------
        | Exception Group Traceback (most recent call last):
        |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\mcp\client\stdio\__init__.py", line 177, in stdio_client
        |     yield read_stream, write_stream
        |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\sessions.py", line 149, in _create_stdio_session
        |     async with ClientSession(read, write, **(session_kwargs or {})) as session:   
        |                ~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
        |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\mcp\shared\session.py", line 220, in __aexit__
        |     return await self._task_group.__aexit__(exc_type, exc_val, exc_tb)
        |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
        |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\anyio\_backends\_asyncio.py", line 772, in __aexit__
        |     raise BaseExceptionGroup(
        |         "unhandled errors in a TaskGroup", self._exceptions
        |     ) from None
        | ExceptionGroup: unhandled errors in a TaskGroup (1 sub-exception)
        +-+---------------- 1 ----------------
          | Traceback (most recent call last):
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\sessions.py", line 150, in _create_stdio_session
          |     yield session
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\sessions.py", line 291, in create_session
          |     yield session
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_mcp_adapters\client.py", line 109, in session
          |     yield session
          |   File "C:\Users\santh\OneDrive\Documents\langchain\web-agent\checks.py", line 105, in main
          |             response = await graph.ainvoke({
          |                        ^^^^^^^^^^^^^^^^^^^^^
          |     ...<18 lines>...
          |             },config=config)
          |             ^^^^^^^^^^^^^^^^
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\pregel\__init__.py", line 2963, in ainvoke
          |     async for chunk in self.astream(
          |     ...<19 lines>...
          |             chunks.append(chunk)
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\pregel\__init__.py", line 2830, in astream
          |     async for _ in runner.atick(
          |     ...<7 lines>...
          |             yield o
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\pregel\runner.py", line 292, in atick
          |     await arun_with_retry(
          |     ...<16 lines>...
          |     )
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\pregel\retry.py", line 136, in arun_with_retry
          |     return await task.proc.ainvoke(task.input, config)
          |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\utils\runnable.py", line 672, in ainvoke
          |     input = await asyncio.create_task(
          |             ^^^^^^^^^^^^^^^^^^^^^^^^^^
          |         step.ainvoke(input, config, **kwargs), context=context
          |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
          |     )
          |     ^
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\utils\runnable.py", line 440, in ainvoke
          |     ret = await self.afunc(*args, **kwargs)
          |           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_core\runnables\config.py", line 616, in run_in_executor
          |     return await asyncio.get_running_loop().run_in_executor(
          |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
          |     ...<2 lines>...
          |     )
          |     ^
          |   File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\concurrent\futures\thread.py", line 59, in run
          |     result = self.fn(*self.args, **self.kwargs)
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langchain_core\runnables\config.py", line 607, in wrapper
          |     return func(*args, **kwargs)
          |   File "C:\Users\santh\OneDrive\Documents\langchain\web-agent\checks.py", line 45, in llm_call
          |     response = agent.invoke(state['messages'])
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\pregel\__init__.py", line 2894, in invoke
          |     for chunk in self.stream(
          |                  ~~~~~~~~~~~^
          |         input,
          |         ^^^^^^
          |     ...<7 lines>...
          |         **kwargs,
          |         ^^^^^^^^^
          |     ):
          |     ^
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\pregel\__init__.py", line 2527, in stream
          |     for _ in runner.tick(
          |              ~~~~~~~~~~~^
          |         [t for t in loop.tasks.values() if not t.writes],
          |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
          |     ...<2 lines>...
          |         schedule_task=loop.accept_push,
          |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
          |     ):
          |     ^
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\pregel\runner.py", line 157, in tick
          |     run_with_retry(
          |     ~~~~~~~~~~~~~~^
          |         t,
          |         ^^
          |     ...<11 lines>...
          |         },
          |         ^^
          |     )
          |     ^
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\pregel\retry.py", line 40, in run_with_retry
          |     return task.proc.invoke(task.input, config)
          |            ~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\utils\runnable.py", line 377, in invoke
          |     ret = self.func(*args, **kwargs)
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\pregel\write.py", line 99, in _write
          |     self.do_write(
          |     ~~~~~~~~~~~~~^
          |         config,
          |         ^^^^^^^
          |         writes,
          |         ^^^^^^^
          |     )
          |     ^
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\pregel\write.py", line 142, in do_write
          |     write(_assemble_writes(writes))
          |           ~~~~~~~~~~~~~~~~^^^^^^^^
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\pregel\write.py", line 199, in _assemble_writes
          |     if ww := w.mapper(w.value):
          |              ~~~~~~~~^^^^^^^^^
          |   File "C:\Users\santh\OneDrive\Documents\langchain\.venv\Lib\site-packages\langgraph\graph\state.py", line 770, in _get_updates
          |     raise InvalidUpdateError(msg)
          | langgraph.errors.InvalidUpdateError: Expected dict, got [HumanMessage(content='\nI want to create a homepage for a futuristic AI robot called AstraBot that helps people with daily tasks like scheduling, home automation, and reminders. The website should have a very clean and modern look, with a sleek design that feels advanced but easy to understand.\n\nThe homepage should include:\n\n1. A large, eye-catching top section with the robot’s name, a short catchy slogan, a button that encourages people to learn more, and a high-quality image of a robot in action.\n2. A section that explains three key features of AstraBot with short descriptions and icons or visuals to go with each.\n3. Testimonials from two happy users, with their names, photos, and a short sentence about how AstraBot helped them.\n4. A final section with a strong call to action inviting visitors to get started or make a purchase.\n5. A footer with some basic links like "About", "Privacy Policy", "Support", and some small icons linking to social media.\n\nThe whole page should feel like it belongs to a next-generation tech product — sleek, professional, and easy to read. Use elegant colors and smooth layout. Make sure it works well on both computers and phones.\n\nAll the content and files should be organized inside a folder called `astrabot_site`.\n\n', additional_kwargs={}, response_metadata={}, id='68ad7178-2917-4c5e-84bc-9bd1654ef7e2')]
          | For troubleshooting, visit: https://python.langchain.com/docs/troubleshooting/errors/INVALID_GRAPH_NODE_RETURN_VALUE
          | During task with name '__start__' and id '35eedd06-06ce-52d2-83a8-d325ddd41460' 
          | During task with name 'llm_call' and id '5a29504d-f63c-0f1f-b366-ddd827ae6c50'  
          +------------------------------------
Exception ignored in: <function BaseSubprocessTransport.__del__ at 0x000002EE09CBF560>
Traceback (most recent call last):
  File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\asyncio\base_subprocess.py", line 130, in __del__
  File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\asyncio\base_subprocess.py", line 107, in close
  File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\asyncio\proactor_events.py", line 109, in close
  File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\asyncio\base_events.py", line 827, in call_soon
  File "C:\Users\santh\AppData\Roaming\uv\python\cpython-3.13.3-windows-x86_64-none\Lib\asyncio\base_events.py", line 550, in _check_closed
RuntimeError: Event loop is closed

I'm unable to understand the cause of the error , help me solve the issue,

[vbarda]

i believe there is an issue here:

def llm_call(state : MessagesState):
    response = agent.invoke(state['messages']) <-- needs to be `agent.invoke({"messages": state["messages"]})`
    return {"messages": response}