github/deer-flow
1
0
Fork 0
mirror of https://github.com/bytedance/deer-flow.git synced 2026-04-25 11:18:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: remove mismatched context param in debug.py to suppress Pydantic warning (#2446)

Browse Source 
* fix: remove mismatched context param in debug.py to suppress Pydantic warning

The ainvoke call passed context={"thread_id": ...} but the agent graph
has no context_schema (ContextT defaults to None), causing a
PydanticSerializationUnexpectedValue warning on every invocation.

Align with the production run_agent path by injecting context via
Runtime into configurable["__pregel_runtime"] instead.

Closes #2445

Made-with: Cursor

* refactor: derive runtime thread_id from config to avoid duplication

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
Made-with: Cursor

---------

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
This commit is contained in:
He Wang 2026-04-23 09:56:57 +08:00 committed by GitHub
parent dbd777fe62
commit c43c803f66
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
backend/debug.py
View File

@ -20,6 +20,7 @@ import logging
from dotenv import load_dotenv from dotenv import load_dotenv
from langchain_core.messages import HumanMessage from langchain_core.messages import HumanMessage
from langgraph.runtime import Runtime
from deerflow.agents import make_lead_agent from deerflow.agents import make_lead_agent
@ -52,6 +53,9 @@ async def main():
} }
} }
runtime = Runtime(context={"thread_id": config["configurable"]["thread_id"]})
config["configurable"]["__pregel_runtime"] = runtime
agent = make_lead_agent(config) agent = make_lead_agent(config)
print("=" * 50) print("=" * 50)
@ -70,7 +74,7 @@ async def main():
# Invoke the agent # Invoke the agent
state = {"messages": [HumanMessage(content=user_input)]} state = {"messages": [HumanMessage(content=user_input)]}
result = await agent.ainvoke(state, config=config, context={"thread_id": "debug-thread-001"}) result = await agent.ainvoke(state, config=config)
# Print the response # Print the response
if result.get("messages"): if result.get("messages"):