wanwu/deer-flow
1
0
Fork 0
mirror of https://gitee.com/wanwujie/deer-flow synced 2026-04-21 13:24:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: support interrupt protocol

Browse Source
This commit is contained in:
He Tao
2025-04-15 16:36:02 +08:00
parent 83a4b668b7
commit 92606fbd4c
4 changed files with 37 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
src/server/app.py
View File

@@ -44,7 +44,7 @@ async def chat_stream(request: ChatRequest):
request.max_plan_iterations,
request.max_step_num,
request.auto_accepted_plan,
request.feedback,
request.interrupt_feedback,
),
media_type="text/event-stream",
)
@@ -56,11 +56,15 @@ async def _astream_workflow_generator(
max_plan_iterations: int,
max_step_num: int,
auto_accepted_plan: bool,
feedback: str,
interrupt_feedback: str,
):
input_ = {"messages": messages, "auto_accepted_plan": auto_accepted_plan}
if not auto_accepted_plan and feedback:
input_ = Command(resume=feedback)
if not auto_accepted_plan and interrupt_feedback:
resume_msg = f"[{interrupt_feedback}]"
# add the last message to the resume message
if messages:
resume_msg += f" {messages[-1]["content"]}"
input_ = Command(resume=resume_msg)
async for agent, _, event_data in graph.astream(
input_,
config={
@@ -68,9 +72,26 @@ async def _astream_workflow_generator(
"max_plan_iterations": max_plan_iterations,
"max_step_num": max_step_num,
},
stream_mode=["messages"],
stream_mode=["messages", "updates"],
subgraphs=True,
):
if isinstance(event_data, dict):
if "__interrupt__" in event_data:
yield _make_event(
"interrupt",
{
"thread_id": thread_id,
"id": event_data["__interrupt__"][0].ns[0],
"role": "assistant",
"content": event_data["__interrupt__"][0].value,
"finish_reason": "interrupt",
"options": [
{"text": "Accept", "value": "accepted"},
{"text": "Edit", "value": "edit_plan"},
],
},
)
continue
message_chunk, message_metadata = cast(
tuple[AIMessageChunk, dict[str, any]], event_data
)