fix

app.log

@@ -49994,3 +49994,310 @@ Traceback (most recent call last):
     raise GraphRecursionError(msg)
 langgraph.errors.GraphRecursionError: Recursion limit of 20 reached without hitting a stop condition. You can increase the limit by setting the `recursion_limit` config key.
 For troubleshooting, visit: https://python.langchain.com/docs/troubleshooting/errors/GRAPH_RECURSION_LIMIT
+2025-06-06 17:07:08:__main__:INFO: Starting the interface
+2025-06-06 17:07:16:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 17:07:26:__main__:INFO: Prompt: You are a helpful assistant.
+2025-06-06 17:07:31:__main__:ERROR: Exception occurred
+Traceback (most recent call last):
+  File "/home/user/app/app.py", line 85, in chat_fn
+    async for stream_mode, chunk in graph.astream(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/__init__.py", line 2655, in astream
+    async for _ in runner.atick(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 400, in atick
+    _panic_or_proceed(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 509, in _panic_or_proceed
+    raise exc
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/retry.py", line 136, in arun_with_retry
+    return await task.proc.ainvoke(task.input, config)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 676, in ainvoke
+    input = await step.ainvoke(input, config, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 440, in ainvoke
+    ret = await self.afunc(*args, **kwargs)
+  File "/home/user/app/graph.py", line 327, in brainstorming_node
+    test_tool_call = ToolCall(name="human_assistance", args={"question": "What materials do you have?"})
+NameError: name 'ToolCall' is not defined
+2025-06-06 17:09:30:__main__:INFO: Starting the interface
+2025-06-06 17:09:33:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 17:09:44:__main__:INFO: Prompt: You are a helpful assistant.
+2025-06-06 17:09:47:__main__:ERROR: Exception occurred
+Traceback (most recent call last):
+  File "/home/user/app/app.py", line 85, in chat_fn
+    async for stream_mode, chunk in graph.astream(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/__init__.py", line 2655, in astream
+    async for _ in runner.atick(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 400, in atick
+    _panic_or_proceed(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 509, in _panic_or_proceed
+    raise exc
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/retry.py", line 136, in arun_with_retry
+    return await task.proc.ainvoke(task.input, config)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 676, in ainvoke
+    input = await step.ainvoke(input, config, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 440, in ainvoke
+    ret = await self.afunc(*args, **kwargs)
+  File "/home/user/app/graph.py", line 328, in brainstorming_node
+    test_message = AIMessage(content=None, tool_calls=[test_tool_call])
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/messages/ai.py", line 187, in __init__
+    super().__init__(content=content, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/messages/base.py", line 71, in __init__
+    super().__init__(content=content, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/load/serializable.py", line 130, in __init__
+    super().__init__(*args, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/pydantic/main.py", line 214, in __init__
+    validated_self = self.__pydantic_validator__.validate_python(data, self_instance=self)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/messages/ai.py", line 224, in _backwards_compat_tool_calls
+    values["tool_calls"] = [
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/messages/ai.py", line 225, in <listcomp>
+    create_tool_call(**{k: v for k, v in tc.items() if k != "type"})
+TypeError: tool_call() missing 1 required keyword-only argument: 'id'
+2025-06-06 17:13:34:__main__:INFO: Starting the interface
+2025-06-06 17:13:43:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 17:13:59:__main__:INFO: Prompt: You are a helpful assistant.
+2025-06-06 17:14:03:__main__:ERROR: Exception occurred
+Traceback (most recent call last):
+  File "/home/user/app/app.py", line 85, in chat_fn
+    async for stream_mode, chunk in graph.astream(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/__init__.py", line 2655, in astream
+    async for _ in runner.atick(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 400, in atick
+    _panic_or_proceed(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 509, in _panic_or_proceed
+    raise exc
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/retry.py", line 136, in arun_with_retry
+    return await task.proc.ainvoke(task.input, config)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 676, in ainvoke
+    input = await step.ainvoke(input, config, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 440, in ainvoke
+    ret = await self.afunc(*args, **kwargs)
+  File "/home/user/app/graph.py", line 334, in brainstorming_node
+    test_message = AIMessage(content=None, tool_calls=[test_tool_call])
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/messages/ai.py", line 187, in __init__
+    super().__init__(content=content, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/messages/base.py", line 71, in __init__
+    super().__init__(content=content, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/load/serializable.py", line 130, in __init__
+    super().__init__(*args, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/pydantic/main.py", line 214, in __init__
+    validated_self = self.__pydantic_validator__.validate_python(data, self_instance=self)
+pydantic_core._pydantic_core.ValidationError: 2 validation errors for AIMessage
+content.str
+  Input should be a valid string [type=string_type, input_value=None, input_type=NoneType]
+    For further information visit https://errors.pydantic.dev/2.10/v/string_type
+content.list[union[str,dict[any,any]]]
+  Input should be a valid list [type=list_type, input_value=None, input_type=NoneType]
+    For further information visit https://errors.pydantic.dev/2.10/v/list_type
+2025-06-06 17:18:55:__main__:INFO: Starting the interface
+2025-06-06 17:19:09:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 17:19:19:__main__:INFO: Prompt: You are a helpful assistant.
+2025-06-06 17:19:22:__main__:ERROR: Exception occurred
+Traceback (most recent call last):
+  File "/home/user/app/app.py", line 85, in chat_fn
+    async for stream_mode, chunk in graph.astream(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/__init__.py", line 2655, in astream
+    async for _ in runner.atick(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 400, in atick
+    _panic_or_proceed(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 509, in _panic_or_proceed
+    raise exc
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/retry.py", line 136, in arun_with_retry
+    return await task.proc.ainvoke(task.input, config)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 676, in ainvoke
+    input = await step.ainvoke(input, config, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 440, in ainvoke
+    ret = await self.afunc(*args, **kwargs)
+  File "/home/user/app/graph.py", line 210, in guidance_node
+    response = await chain.ainvoke({"messages": state.messages}, config=config)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/runnables/base.py", line 3089, in ainvoke
+    input_ = await coro_with_context(part(), context, create_task=True)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/runnables/base.py", line 5444, in ainvoke
+    return await self.bound.ainvoke(
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/language_models/chat_models.py", line 394, in ainvoke
+    llm_result = await self.agenerate_prompt(
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/language_models/chat_models.py", line 968, in agenerate_prompt
+    return await self.agenerate(
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/language_models/chat_models.py", line 926, in agenerate
+    raise exceptions[0]
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/language_models/chat_models.py", line 1083, in _agenerate_with_cache
+    async for chunk in self._astream(messages, stop=stop, **kwargs):
+  File "/usr/local/lib/python3.10/site-packages/langchain_anthropic/chat_models.py", line 1394, in _astream
+    _handle_anthropic_bad_request(e)
+  File "/usr/local/lib/python3.10/site-packages/langchain_anthropic/chat_models.py", line 1374, in _astream
+    stream = await self._acreate(payload)
+  File "/usr/local/lib/python3.10/site-packages/langchain_anthropic/chat_models.py", line 1322, in _acreate
+    return await self._async_client.messages.create(**payload)
+  File "/usr/local/lib/python3.10/site-packages/anthropic/resources/messages/messages.py", line 2229, in create
+    return await self._post(
+  File "/usr/local/lib/python3.10/site-packages/anthropic/_base_client.py", line 1819, in post
+    return await self.request(cast_to, opts, stream=stream, stream_cls=stream_cls)
+  File "/usr/local/lib/python3.10/site-packages/anthropic/_base_client.py", line 1626, in request
+    raise self._make_status_error_from_response(err.response) from None
+anthropic.BadRequestError: Error code: 400 - {'type': 'error', 'error': {'type': 'invalid_request_error', 'message': 'messages.1: `tool_use` ids were found without `tool_result` blocks immediately after: 5463c2ea-8caf-48fc-a755-e23181439455. Each `tool_use` block must have a corresponding `tool_result` block in the next message.'}}
+2025-06-06 17:44:15:__main__:INFO: Starting the interface
+2025-06-06 17:44:21:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 17:44:29:__main__:INFO: Prompt: You are a helpful assistant.
+2025-06-06 17:44:38:__main__:ERROR: Exception occurred
+Traceback (most recent call last):
+  File "/home/user/app/app.py", line 85, in chat_fn
+    async for stream_mode, chunk in graph.astream(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/__init__.py", line 2655, in astream
+    async for _ in runner.atick(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 400, in atick
+    _panic_or_proceed(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 509, in _panic_or_proceed
+    raise exc
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/retry.py", line 136, in arun_with_retry
+    return await task.proc.ainvoke(task.input, config)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 676, in ainvoke
+    input = await step.ainvoke(input, config, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 440, in ainvoke
+    ret = await self.afunc(*args, **kwargs)
+  File "/home/user/app/graph.py", line 210, in guidance_node
+    response = await chain.ainvoke({"messages": state.messages}, config=config)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/runnables/base.py", line 3089, in ainvoke
+    input_ = await coro_with_context(part(), context, create_task=True)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/runnables/base.py", line 5444, in ainvoke
+    return await self.bound.ainvoke(
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/language_models/chat_models.py", line 394, in ainvoke
+    llm_result = await self.agenerate_prompt(
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/language_models/chat_models.py", line 968, in agenerate_prompt
+    return await self.agenerate(
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/language_models/chat_models.py", line 926, in agenerate
+    raise exceptions[0]
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/language_models/chat_models.py", line 1083, in _agenerate_with_cache
+    async for chunk in self._astream(messages, stop=stop, **kwargs):
+  File "/usr/local/lib/python3.10/site-packages/langchain_anthropic/chat_models.py", line 1394, in _astream
+    _handle_anthropic_bad_request(e)
+  File "/usr/local/lib/python3.10/site-packages/langchain_anthropic/chat_models.py", line 1374, in _astream
+    stream = await self._acreate(payload)
+  File "/usr/local/lib/python3.10/site-packages/langchain_anthropic/chat_models.py", line 1322, in _acreate
+    return await self._async_client.messages.create(**payload)
+  File "/usr/local/lib/python3.10/site-packages/anthropic/resources/messages/messages.py", line 2229, in create
+    return await self._post(
+  File "/usr/local/lib/python3.10/site-packages/anthropic/_base_client.py", line 1819, in post
+    return await self.request(cast_to, opts, stream=stream, stream_cls=stream_cls)
+  File "/usr/local/lib/python3.10/site-packages/anthropic/_base_client.py", line 1626, in request
+    raise self._make_status_error_from_response(err.response) from None
+anthropic.BadRequestError: Error code: 400 - {'type': 'error', 'error': {'type': 'invalid_request_error', 'message': 'messages.1: `tool_use` ids were found without `tool_result` blocks immediately after: fa20aec0-e08a-42dc-b122-09be53ba1b26. Each `tool_use` block must have a corresponding `tool_result` block in the next message.'}}
+2025-06-06 17:49:43:__main__:INFO: Starting the interface
+2025-06-06 17:49:48:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 17:50:04:__main__:INFO: Prompt: You are a helpful assistant.
+2025-06-06 17:50:09:__main__:ERROR: Exception occurred
+Traceback (most recent call last):
+  File "/home/user/app/app.py", line 85, in chat_fn
+    async for stream_mode, chunk in graph.astream(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/__init__.py", line 2655, in astream
+    async for _ in runner.atick(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 400, in atick
+    _panic_or_proceed(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 509, in _panic_or_proceed
+    raise exc
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/retry.py", line 136, in arun_with_retry
+    return await task.proc.ainvoke(task.input, config)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 676, in ainvoke
+    input = await step.ainvoke(input, config, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 440, in ainvoke
+    ret = await self.afunc(*args, **kwargs)
+  File "/home/user/app/graph.py", line 261, in brainstorming_node
+    result = human_assistance("What materials do you have?")
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/_api/deprecation.py", line 191, in warning_emitting_wrapper
+    return wrapped(*args, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/tools/base.py", line 893, in __call__
+    return self.run(tool_input, callbacks=callbacks)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/tools/base.py", line 771, in run
+    raise error_to_raise
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/tools/base.py", line 740, in run
+    response = context.run(self._run, *tool_args, **tool_kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/tools/structured.py", line 95, in _run
+    raise NotImplementedError(msg)
+NotImplementedError: StructuredTool does not support sync invocation.
+2025-06-06 17:59:36:__main__:INFO: Starting the interface
+2025-06-06 17:59:43:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 18:02:02:__main__:INFO: Prompt: You are a helpful assistant.
+2025-06-06 18:02:06:__main__:ERROR: Exception occurred
+Traceback (most recent call last):
+  File "/home/user/app/app.py", line 97, in chat_fn
+    async for stream_mode, chunk in graph.astream(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/__init__.py", line 2655, in astream
+    async for _ in runner.atick(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 400, in atick
+    _panic_or_proceed(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 509, in _panic_or_proceed
+    raise exc
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/retry.py", line 136, in arun_with_retry
+    return await task.proc.ainvoke(task.input, config)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 676, in ainvoke
+    input = await step.ainvoke(input, config, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 440, in ainvoke
+    ret = await self.afunc(*args, **kwargs)
+  File "/home/user/app/graph.py", line 261, in brainstorming_node
+    result = await human_assistance.ainvoke({"query": "What materials do you have?"})
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/tools/structured.py", line 66, in ainvoke
+    return await super().ainvoke(input, config, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/tools/base.py", line 520, in ainvoke
+    return await self.arun(tool_input, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/tools/base.py", line 884, in arun
+    raise error_to_raise
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/tools/base.py", line 853, in arun
+    response = await coro_with_context(coro, context)
+  File "/usr/local/lib/python3.10/site-packages/langchain_core/tools/structured.py", line 110, in _arun
+    return await self.coroutine(*args, **kwargs)
+  File "/home/user/app/graph.py", line 65, in human_assistance
+    human_response = await interrupt({"query": query})  # async wait
+  File "/usr/local/lib/python3.10/site-packages/langgraph/types.py", line 523, in interrupt
+    conf = get_config()["configurable"]
+  File "/usr/local/lib/python3.10/site-packages/langgraph/config.py", line 29, in get_config
+    raise RuntimeError("Called get_config outside of a runnable context")
+RuntimeError: Called get_config outside of a runnable context
+2025-06-06 18:08:07:__main__:INFO: Starting the interface
+2025-06-06 18:08:16:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 18:08:33:__main__:INFO: Prompt: You are a helpful assistant.
+2025-06-06 18:08:36:__main__:ERROR: Exception occurred
+Traceback (most recent call last):
+  File "/home/user/app/app.py", line 97, in chat_fn
+    async for stream_mode, chunk in graph.astream(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/__init__.py", line 2655, in astream
+    async for _ in runner.atick(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 400, in atick
+    _panic_or_proceed(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/runner.py", line 509, in _panic_or_proceed
+    raise exc
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/retry.py", line 136, in arun_with_retry
+    return await task.proc.ainvoke(task.input, config)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 676, in ainvoke
+    input = await step.ainvoke(input, config, **kwargs)
+  File "/usr/local/lib/python3.10/site-packages/langgraph/utils/runnable.py", line 440, in ainvoke
+    ret = await self.afunc(*args, **kwargs)
+  File "/home/user/app/graph.py", line 235, in brainstorming_node
+    from langgraph.types import ToolCall
+ImportError: cannot import name 'ToolCall' from 'langgraph.types' (/usr/local/lib/python3.10/site-packages/langgraph/types.py)
+2025-06-06 18:12:07:__main__:INFO: Starting the interface
+2025-06-06 18:12:15:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 18:12:24:__main__:INFO: Prompt: You are a helpful assistant.
+2025-06-06 18:13:00:__main__:ERROR: Exception occurred
+Traceback (most recent call last):
+  File "/home/user/app/app.py", line 97, in chat_fn
+    async for stream_mode, chunk in graph.astream(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/__init__.py", line 2677, in astream
+    raise GraphRecursionError(msg)
+langgraph.errors.GraphRecursionError: Recursion limit of 20 reached without hitting a stop condition. You can increase the limit by setting the `recursion_limit` config key.
+For troubleshooting, visit: https://python.langchain.com/docs/troubleshooting/errors/GRAPH_RECURSION_LIMIT
+2025-06-06 18:14:57:__main__:INFO: Starting the interface
+2025-06-06 18:15:04:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 18:16:24:__main__:INFO: Starting the interface
+2025-06-06 18:16:36:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 18:17:54:__main__:INFO: Prompt: You are a helpful assistant.
+2025-06-06 18:18:36:__main__:ERROR: Exception occurred
+Traceback (most recent call last):
+  File "/home/user/app/app.py", line 97, in chat_fn
+    async for stream_mode, chunk in graph.astream(
+  File "/usr/local/lib/python3.10/site-packages/langgraph/pregel/__init__.py", line 2677, in astream
+    raise GraphRecursionError(msg)
+langgraph.errors.GraphRecursionError: Recursion limit of 20 reached without hitting a stop condition. You can increase the limit by setting the `recursion_limit` config key.
+For troubleshooting, visit: https://python.langchain.com/docs/troubleshooting/errors/GRAPH_RECURSION_LIMIT
+2025-06-06 18:18:39:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 18:31:54:__main__:INFO: Starting the interface
+2025-06-06 18:32:00:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 18:32:07:__main__:INFO: Prompt: You are a helpful assistant.
+2025-06-06 18:34:27:__main__:INFO: Starting the interface
+2025-06-06 18:34:31:__main__:INFO: Greeting added for new user via handle_initial_greeting_load.
+2025-06-06 18:35:28:__main__:INFO: Prompt: You are a helpful assistant.

app.py

@@ -66,12 +66,24 @@ async def chat_fn(user_input: str, history: dict, input_graph_state: dict, uuid:
         }
         if prompt:
             input_graph_state["prompt"] = prompt
-        if "messages" not in input_graph_state:
-            input_graph_state["messages"] = []
-        input_graph_state["messages"].append(
-            HumanMessage(user_input[:USER_INPUT_MAX_LENGTH])
-        )
-        input_graph_state["messages"] = input_graph_state["messages"][-TRIM_MESSAGE_LENGTH:]
+
+        if input_graph_state.get("awaiting_human_input"):
+            input_graph_state["messages"].append(
+                ToolMessage(
+                    tool_call_id=input_graph_state.pop("human_assistance_tool_id"),
+                    content=user_input
+                )
+            )
+            input_graph_state["awaiting_human_input"] = False
+        else:
+            # New user message
+            if "messages" not in input_graph_state:
+                input_graph_state["messages"] = []
+            input_graph_state["messages"].append(
+                HumanMessage(user_input[:USER_INPUT_MAX_LENGTH])
+            )
+            input_graph_state["messages"] = input_graph_state["messages"][-TRIM_MESSAGE_LENGTH:]
+
         config = RunnableConfig(
             recursion_limit=20,
             run_name="user_chat",
@@ -93,18 +105,34 @@ async def chat_fn(user_input: str, history: dict, input_graph_state: dict, uuid:
                 if hasattr(last_message, "tool_calls"):
                     for msg_tool_call in last_message.tool_calls:
                         tool_name: str = msg_tool_call['name']
+
                         if tool_name == "tavily_search_results_json":
                             query = msg_tool_call['args']['query']
                             waiting_output_seq.append(f"Searching for '{query}'...")
                             yield "\n".join(waiting_output_seq), gr.skip(), gr.skip()
+
                         # download_website_text is the name of the function defined in graph.py
                         elif tool_name == "download_website_text":
                             url = msg_tool_call['args']['url']
                             waiting_output_seq.append(f"Downloading text from '{url}'...")
                             yield "\n".join(waiting_output_seq), gr.skip(), gr.skip()
+
+                        elif tool_name == "human_assistance":
+                            query = msg_tool_call["args"]["query"]
+                            waiting_output_seq.append(f"👤 Human input needed: {query}")
+
+                            # Save state to resume after user provides input
+                            input_graph_state["awaiting_human_input"] = True
+                            input_graph_state["human_assistance_tool_id"] = msg_tool_call["id"]
+
+                            # Show input textbox to user and pause graph execution
+                            yield "\n".join(waiting_output_seq), gr.Textbox(visible=True, label="Your input"), gr.skip()
+                            return  # Pause execution, resume in next call
+
                         else:
                             waiting_output_seq.append(f"Running {tool_name}...")
                             yield "\n".join(waiting_output_seq), gr.skip(), gr.skip()
+
             elif stream_mode == "messages":
                 msg, metadata = chunk
                 # print("output: ", msg, metadata)
@@ -119,10 +147,12 @@ async def chat_fn(user_input: str, history: dict, input_graph_state: dict, uuid:
                                 current_chunk_text += block.get("text", "")
                             elif isinstance(block, str): # Fallback if content is list of strings
                                 current_chunk_text += block
+
                     
                     if current_chunk_text: # Only add and yield if there's actually text
                         output += current_chunk_text
                         yield output, gr.skip(), gr.skip()
+
         # Trigger for asking follow up questions
         # + store the graph state for next iteration
         # yield output, dict(final_state), gr.skip()

graph.py

@@ -4,9 +4,11 @@ import logging
 import os
 from typing import Annotated
 from typing_extensions import TypedDict
+import uuid
+
 
 import aiohttp
-from langchain_core.messages import AIMessage, HumanMessage, AnyMessage
+from langchain_core.messages import AIMessage, HumanMessage, AnyMessage, ToolCall
 
 from langchain_core.prompts import ChatPromptTemplate, MessagesPlaceholder
 from langchain_core.tools import tool
@@ -58,9 +60,9 @@ def evaluate_idea_completion(response) -> bool:
     return all(keyword in response_text for keyword in required_keywords)
 
 @tool
-def human_assistance(query: str) -> str:
+async def human_assistance(query: str) -> str:
     """Request assistance from a human."""
-    human_response = interrupt({"query": query})
+    human_response = await interrupt({"query": query})  # async wait
     return human_response["data"]
 
 @tool
@@ -223,118 +225,113 @@ async def guidance_node(state: GraphProcessingState, config=None):
     }
 
 async def brainstorming_node(state: GraphProcessingState, config=None):
-    print("\n--- Brainstorming Node (Debug) ---")
-
+    print("\n--- brainstorming_node (Debug via print) ---")
     print(f"Prompt: {state.prompt}")
+
+    # Log the content of each message
     for message in state.messages:
-        if isinstance(message, HumanMessage):
-            print(f"Human: {message.content}")
-        elif isinstance(message, AIMessage):
-            if message.content:
-                if isinstance(message.content, list):
-                    texts = [item.get('text', '') for item in message.content if isinstance(item, dict) and 'text' in item]
-                    if texts:
-                        print(f"AI: {' '.join(texts)}")
-                elif isinstance(message.content, str):
-                    print(f"AI: {message.content}")
-        elif isinstance(message, SystemMessage):
-            print(f"System: {message.content}")
-        elif isinstance(message, ToolMessage):
-            print(f"Tool: {message.content}")
+        if isinstance(message, (HumanMessage, AIMessage, SystemMessage, ToolMessage)):
+            print(f"Message Content: {message.content}")
 
-    print(f"Tools Enabled: {state.tools_enabled}")
+    print(f"Tools called: {state.tool_call_required}")
     print(f"Search Enabled: {state.search_enabled}")
     print(f"Next Stage: {state.next_stage}")
 
+    # Log boolean completion flags
     print(f"Idea Complete: {state.idea_complete}")
     print(f"Brainstorming Complete: {state.brainstorming_complete}")
     print(f"Planning Complete: {state.planning_complete}")
     print(f"Drawing Complete: {state.drawing_complete}")
     print(f"Product Searching Complete: {state.product_searching_complete}")
     print(f"Purchasing Complete: {state.purchasing_complete}")
+    print("--- End Guidance Node Debug ---")
 
-    # if not model:
-    #     return {"messages": [AIMessage(content="Model not available for brainstorming.")]}
-
-    # # Define the system prompt guiding the brainstorming assistant
-    # brainstorming_system_prompt = ChatPromptTemplate.from_messages(
-    #     [
-    #         ("system",
-    #          "You are a brainstorming assistant for DIY projects. Your goal is to help the user finalize a single, specific DIY project idea. "
-    #          "The project idea MUST satisfy these critical criteria:\n"
-    #          "1. Buildable by an average person with basic DIY skills.\n"
-    #          "2. Uses only materials and basic tools commonly available in general hardware stores, craft stores, or supermarkets worldwide. "
-    #          "(e.g., wood, screws, glue, paint, fabric, cardboard, basic hand tools like screwdrivers, hammers, saws, drills. "
-    #          "AVOID specialized electronic components, 3D printing, specific brand items not universally available, or complex machinery.)\n"
-    #          "3. The final product should be a tangible item.\n\n"
-    #          "Your interaction flow:\n"
-    #          "- Engage with the user to understand their interests or initial thoughts.\n"
-    #          "- Propose ideas or refine user's suggestions to meet the criteria.\n"
-    #          "- If an idea proposed by you or the user clearly meets all criteria and you believe it's a good final choice, respond ONLY with the exact phrase: "
-    #          "'IDEA FINALIZED: [Name of the Idea]'. Example: 'IDEA FINALIZED: Simple Wooden Spice Rack'. "
-    #          "Do not add any other text before or after this phrase if you use it.\n"
-    #          "- If you need more information from the user to refine an idea, or if their current suggestion doesn't meet the criteria, ask clarifying questions. "
-    #          "Guide them towards simpler, more accessible options.\n"
-    #          "- If you are stuck, the user's request is too vague for you to make progress towards a suitable idea, or they propose something clearly outside the "
-    #          "'universally available materials' constraint, and you need their direct input to clarify fundamental aspects, you should use the 'human_assistance' tool. "
-    #          "Frame your request for the human clearly. For example: 'To ensure the idea is simple enough, could you tell me what kind of tools you are comfortable using?' "
-    #          "or 'The idea of a custom electronic gadget is interesting, but finding parts globally is hard. Could we think of a non-electronic version, or what's the core function "
-    #          "you want from it that we could achieve with simpler materials?'"
-    #          ),
-    #         MessagesPlaceholder(variable_name="messages"),
-    #     ]
-    # )
-
-    # # Tools allowed for brainstorming
-    # node_tools = [human_assistance]
-    # if state.search_enabled and tavily_search_tool:  # only add search tool if enabled and initialized
-    #     node_tools.append(tavily_search_tool)
-
-    # llm_with_tools = model.bind_tools(node_tools)
-    # chain = brainstorming_system_prompt | llm_with_tools
-
-    # # Pass current messages from the state to the chain
-    # response_message = await chain.ainvoke({"messages": state.messages}, config=config)
-
-    # updates = {"messages": [response_message]}
-
-    # if isinstance(response_message, AIMessage) and response_message.content:
-    #     content = response_message.content.strip()
-
-    #     if content.startswith("IDEA FINALIZED:"):
-    #         updates["brainstorming_complete"] = True
-    #         updates["tool_call_required"] = False
-    #         updates["loop_brainstorming"] = False
-    #         print(f"✅ Brainstorming complete! Idea: {content}")
-
-    #     elif getattr(response_message, "tool_calls", None):
-    #         updates["tool_call_required"] = True
-    #         updates["loop_brainstorming"] = False
-    #         print(f"🛠️ Brainstorming node initiated tool call(s): {response_message.tool_calls}")
-
-    #     else:
-    #         updates["tool_call_required"] = False
-    #         updates["loop_brainstorming"] = True
-    #         print(f"💬 Brainstorming node continues discussion: {content}")
-
-    # else:
-    #     # If no proper response, keep looping brainstorming
-    #     updates["tool_call_required"] = False
-    #     updates["loop_brainstorming"] = True
-
-    # print("\n--- End Brainstorming Node Debug ---")
-    
-    test_tool_call = ToolCall(name="human_assistance", args={"question": "What materials do you have?"})
-    test_message = AIMessage(content=None, tool_calls=[test_tool_call])
+    # Check if model is available
+    if not model:
+        return {"messages": [AIMessage(content="Model not available for brainstorming.")]}
 
-    updates = {
-        "messages": [test_message],
-        "tool_call_required": True,
-        "loop_brainstorming": False,
-    }
+    # Filter out messages with empty content
+    filtered_messages = [
+        message for message in state.messages
+        if isinstance(message, (HumanMessage, AIMessage, SystemMessage, ToolMessage)) and message.content
+    ]
 
-    return updates
+    # Ensure there is at least one message with content
+    if not filtered_messages:
+        filtered_messages.append(AIMessage(content="No valid messages provided."))
 
+    # Define the system prompt guiding the brainstorming assistant
+    brainstorming_system_prompt = ChatPromptTemplate.from_messages(
+        [
+            ("system",
+             "You are a brainstorming assistant for DIY projects. Your goal is to help the user finalize a single, specific DIY project idea. "
+             "The project idea MUST satisfy these critical criteria:\n"
+             "1. Buildable by an average person with basic DIY skills.\n"
+             "2. Uses only materials and basic tools commonly available in general hardware stores, craft stores, or supermarkets worldwide. "
+             "(e.g., wood, screws, glue, paint, fabric, cardboard, basic hand tools like screwdrivers, hammers, saws, drills. "
+             "AVOID specialized electronic components, 3D printing, specific brand items not universally available, or complex machinery.)\n"
+             "3. The final product should be a tangible item.\n\n"
+             "Your interaction flow:\n"
+             "- Engage with the user to understand their interests or initial thoughts.\n"
+             "- Propose ideas or refine user's suggestions to meet the criteria.\n"
+             "- If an idea proposed by you or the user clearly meets all criteria and you believe it's a good final choice, respond ONLY with the exact phrase: "
+             "'IDEA FINALIZED: [Name of the Idea]'. Example: 'IDEA FINALIZED: Simple Wooden Spice Rack'. "
+             "Do not add any other text before or after this phrase if you use it.\n"
+             "- If you need more information from the user to refine an idea, or if their current suggestion doesn't meet the criteria, ask clarifying questions. "
+             "Guide them towards simpler, more accessible options.\n"
+             "- If you are stuck, the user's request is too vague for you to make progress towards a suitable idea, or they propose something clearly outside the "
+             "'universally available materials' constraint, and you need their direct input to clarify fundamental aspects, you should use the 'human_assistance' tool. "
+             "Frame your request for the human clearly. For example: 'To ensure the idea is simple enough, could you tell me what kind of tools you are comfortable using?' "
+             "or 'The idea of a custom electronic gadget is interesting, but finding parts globally is hard. Could we think of a non-electronic version, or what's the core function "
+             "you want from it that we could achieve with simpler materials?'"
+             ),
+            MessagesPlaceholder(variable_name="messages"),
+        ]
+    )
+
+    # Tools allowed for brainstorming
+    node_tools = [human_assistance]
+    if state.search_enabled and tavily_search_tool:  # only add search tool if enabled and initialized
+        node_tools.append(tavily_search_tool)
+
+    llm_with_tools = model.bind_tools(node_tools)
+    chain = brainstorming_system_prompt | llm_with_tools
+
+    # Pass filtered messages to the chain
+    response_message = await chain.ainvoke({"messages": filtered_messages}, config=config)
+
+    updates = {"messages": [response_message]}
+    print('response from brainstorm', response_message)
+
+    if isinstance(response_message, AIMessage) and response_message.content:
+        content = response_message.content.strip()
+
+        if content.startswith("IDEA FINALIZED:"):
+            print('final idea')
+            updates["brainstorming_complete"] = True
+            updates["tool_call_required"] = False
+            updates["loop_brainstorming"] = False
+            print(f"✅ Brainstorming complete! Idea: {content}")
+
+        elif getattr(response_message, "tool_calls", None):
+            print('tool call requested')
+            updates["tool_call_required"] = True
+            updates["loop_brainstorming"] = False
+            print(f"🛠️ Brainstorming node initiated tool call(s): {response_message.tool_calls}")
+
+        else:
+            print('keep brainstorming')
+            updates["tool_call_required"] = False
+            updates["loop_brainstorming"] = True
+            print(f"💬 Brainstorming node continues discussion: {content}")
+
+    else:
+        # If no proper response, keep looping brainstorming
+        updates["tool_call_required"] = False
+        updates["loop_brainstorming"] = True
+
+    print("\n--- End Brainstorming Node Debug ---")
+    return updates
 
 def brainstorming_routing(state: GraphProcessingState) -> str:
     print("\n--- brainstorming_routing Edge (Debug via print) ---") # Added a newline for clarity
@@ -449,13 +446,17 @@ def define_workflow() -> CompiledStateGraph:
 
     # Edges
     workflow.add_edge("tools", "guidance_node")
-    workflow.add_edge("planning_node", "guidance_node")
-    workflow.add_edge("brainstorming_node", "guidance_node")
-    workflow.add_edge("brainstorming_node", "tools")
-    workflow.add_edge("tools", "brainstorming_node")
-
+    # workflow.add_edge("planning_node", "guidance_node")
+    # workflow.add_edge("brainstorming_node", "guidance_node")
+    # workflow.add_edge("brainstorming_node", "tools")
+    # workflow.add_edge("tools", "brainstorming_node")
+
+    workflow.add_conditional_edges(
+        "brainstorming_node",
+        tools_condition,
+    )
     workflow.add_conditional_edges("guidance_node", guidance_routing)
-    workflow.add_conditional_edges("brainstorming_node", brainstorming_routing)
+    # workflow.add_conditional_edges("brainstorming_node", brainstorming_routing)
 
     # # Set end nodes
     workflow.set_entry_point("guidance_node")
@@ -558,3 +559,8 @@ graph = define_workflow()
 #         "messages": response,
 #         "idea_complete": idea_complete
 #     }
+
+
+
+
+  #