lxy/DevFlow
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复: B-03b-R6 human_node send 缺 await + R7 前端契约失配（P0 审批链断裂）

Browse Source 
R6: human_node.rs:41 发 HumanApprovalRequest 缺 .await（async fn send 的 Future 被 let _ = 丢弃未 poll，Request 从未进 channel，审批链最上游断裂，B-03a 重写引入，7 单测不覆盖 Request 发出故漏）
R7: project.ts:214 type 'HumanApprovalRequest'→'human_approval_request'(serde rename snake_case) + :215 payload.event.data→payload.event 扁平取字段(WorkflowEvent 无 data 包装)
来源: workflow-approval-review-2026-06-14.md §0/§1(31-agent 审查头号 P0)；cargo/vue-tsc 0 err / df-nodes 14 test pass
This commit is contained in:
绝尘
2026-06-14 16:32:14 +08:00
parent 3e042f049b
commit 0bb96fc509
2 changed files with 13 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
crates/df-nodes/src/human_node.rs
View File

@@ -38,13 +38,16 @@ impl Node for HumanNode {
let mut rx = ctx.event_bus.subscribe(); let mut rx = ctx.event_bus.subscribe();
// 2. 发送人工审批请求到事件总线 // 2. 发送人工审批请求到事件总线
let _ = ctx.event_bus.send(WorkflowEvent::HumanApprovalRequest { // send 是 async fn(broadcast 同步发但 async 包装),必须 await 否则 Future 不 poll、Request 不进 channel(B-03b-R6)
execution_id: ctx.execution_id.clone(), let _ = ctx.event_bus
node_id: ctx.node_id.clone(), .send(WorkflowEvent::HumanApprovalRequest {
title: title.to_string(), execution_id: ctx.execution_id.clone(),
description: description.to_string(), node_id: ctx.node_id.clone(),
options: options.clone(), title: title.to_string(),
}); description: description.to_string(),
options: options.clone(),
})
.await;
// 3. select! 循环：Response / 超时 / 取消 // 3. select! 循环：Response / 超时 / 取消
let deadline = tokio::time::Instant::now() + Duration::from_secs(timeout_secs); let deadline = tokio::time::Instant::now() + Duration::from_secs(timeout_secs);

5
src/stores/project.ts
View File

@@ -211,8 +211,9 @@ function createStore() {
try { try {
state.liveEvents.push(payload) state.liveEvents.push(payload)
// 处理人工审批请求 // 处理人工审批请求
if (payload.event?.type === 'HumanApprovalRequest') { // WorkflowEvent serde tag=type rename_all=snake_case → type='human_approval_request'，字段扁平(无 data 包装)(B-03b-R7)
state.pendingApproval = payload.event.data as typeof state.pendingApproval if (payload.event?.type === 'human_approval_request') {
state.pendingApproval = payload.event as unknown as typeof state.pendingApproval
} }
} catch (e) { } catch (e) {
console.error('处理工作流事件失败:', e, payload) console.error('处理工作流事件失败:', e, payload)