From 671020b511c9c66a6a64bb205607b69282ded277 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=BB=9D=E5=B0=98?= <237809796@qq.com> Date: Tue, 29 Sep 2026 15:17:49 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B8=85=E7=90=86:=20=E6=B3=A8=E9=87=8A?= =?UTF-8?q?=E5=8E=BB=E8=AE=BE=E8=AE=A1=E4=BB=BB=E5=8A=A1=E7=BC=96=E5=8F=B7?= =?UTF-8?q?=E5=89=8D=E7=BC=80=E6=94=B9=E6=8F=8F=E8=BF=B0=E6=80=A7=E8=A1=A8?= =?UTF-8?q?=E8=BF=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/commands/ai/agentic/workflow_context.rs | 2 +- src-tauri/src/commands/ai/mod.rs | 2 +- src-tauri/src/commands/workflow.rs | 12 ++++++------ 3 files changed, 8 insertions(+), 8 deletions(-) diff --git a/src-tauri/src/commands/ai/agentic/workflow_context.rs b/src-tauri/src/commands/ai/agentic/workflow_context.rs index 9fa2c3f..8d7eeb1 100644 --- a/src-tauri/src/commands/ai/agentic/workflow_context.rs +++ b/src-tauri/src/commands/ai/agentic/workflow_context.rs @@ -1,6 +1,6 @@ //! 工作流 DAG 上下文注入 — 当会话关联工作流时,将活跃路径注入 system prompt //! -//! T4 实现,完整链路(生产侧已接通): +//! 完整链路(生产侧已接通): //! - 生产:`run_workflow_inner`(workflow.rs)AI 路径(conv_id Some)启动时调 //! `build_dag_summary` 产出摘要写入 `PerConvState.workflow_dag_summary` //! (`workflow_id` 存本次执行 ID,非模板 ID);执行闭包终态(completed/failed) diff --git a/src-tauri/src/commands/ai/mod.rs b/src-tauri/src/commands/ai/mod.rs index 298ab7b..a9d19d1 100644 --- a/src-tauri/src/commands/ai/mod.rs +++ b/src-tauri/src/commands/ai/mod.rs @@ -1143,7 +1143,7 @@ pub(crate) struct ToolCallDraft { /// 不在此推进任务状态 —— workflow.rs::run_workflow 内部已按 task_id+target_status 自动联动 /// (成功推进到 target / 失败按 regression_target 退回),此处不重复。 /// -/// `conv_id`(T4 会话关联)末参透传 run_workflow_inner:调用方带发起会话 ID 时, +/// `conv_id`(工作流会话关联)末参透传 run_workflow_inner:调用方带发起会话 ID 时, /// 启动写 workflow_id/workflow_dag_summary、终态回写摘要,供 agentic loop 注入 system prompt。 pub(crate) async fn execute_run_workflow_for_tool( app: &tauri::AppHandle, diff --git a/src-tauri/src/commands/workflow.rs b/src-tauri/src/commands/workflow.rs index 2762c19..dde4424 100644 --- a/src-tauri/src/commands/workflow.rs +++ b/src-tauri/src/commands/workflow.rs @@ -120,7 +120,7 @@ pub async fn run_workflow( /// - execute_run_workflow_for_tool(AI 工具经 ai_approve 审批后执行)传 "ai" /// 原硬编码 "manual" 致 AI 路径误标,改由调用方透传。 /// -/// `conv_id` T4 会话关联:Some(AI 路径)时启动写入 workflow_id(存本次执行 ID,非模板 ID)与 +/// `conv_id` 工作流会话关联:Some(AI 路径)时启动写入 workflow_id(存本次执行 ID,非模板 ID)与 /// workflow_dag_summary 进会话状态,供 agentic loop 每轮 build_runtime_prompt 注入; /// 执行闭包终态(completed/failed)回写终态摘要。会话不存在则静默跳过。 /// 命令层手动触发无会话上下文,传 None 零关联。 @@ -169,7 +169,7 @@ pub async fn run_workflow_inner( // 3. 写入执行记录(status=running) let execution_id: ExecutionId = new_id().into(); let dag_json = serde_json::to_string(&dag).map_err(err_str)?; - // T4: DAG 摘要启动态(无当前节点),启动写入与终态刷新共用同一基础文本, + // DAG 摘要启动态(无当前节点),启动写入与终态刷新共用同一基础文本, // 闭包外算好 move 进闭包,闭包内只拼状态行不重算。 let dag_summary = build_dag_summary(&dag, None); let conv_id = conv_id.map(|s| s.to_string()); @@ -192,7 +192,7 @@ pub async fn run_workflow_inner( .await .map_err(err_str)?; - // T4 生产侧:AI 路径启动时把执行 ID 与 DAG 摘要写入会话状态,接通 + // 生产侧接线:AI 路径启动时把执行 ID 与 DAG 摘要写入会话状态,接通 // 「生产者 → workflow_dag_summary → build_runtime_prompt 注入」链路。 // 存的是本次执行 ID(非模板 ID);会话不存在(已删除/无效 conv_id)静默跳过, // 与消费侧 conv_read 短路语义一致(不惰性创建空会话)。 @@ -304,7 +304,7 @@ pub async fn run_workflow_inner( // F-260616-06 ②-2: move task_id / target_status 进闭包供完成/失败回调使用 let cb_task_id = task_id.clone(); let cb_target_status = target_status.clone(); - // T4 终态刷新物料:conv_id + 基础摘要 + 会话锁句柄 move 进执行闭包 + // 终态刷新物料:conv_id + 基础摘要 + 会话锁句柄 move 进执行闭包 let cb_conv_id = conv_id.clone(); let cb_dag_summary = dag_summary.clone(); let ai_session = state.ai_session.clone(); @@ -409,7 +409,7 @@ pub async fn run_workflow_inner( state_registry.lock().await.remove(&exec_id); // failed_node 从状态机取首个失败/取消节点(R9⑪: 原 String::new() 空值), - // 失败补发事件与 T4 会话终态摘要共用,提到分支外计算。 + // 失败补发事件与会话终态摘要共用,提到分支外计算。 let failed_node = if error.is_some() { executor .state_machine() @@ -432,7 +432,7 @@ pub async fn run_workflow_inner( .await; } - // T4 终态刷新:工作流终态后把完成/失败结论写回会话摘要,agentic loop + // 终态刷新:工作流终态后把完成/失败结论写回会话摘要,agentic loop // 下一轮注入终态而非启动时的「完成: 待执行器上报」。 // 会话不存在(已删除)静默跳过;手动路径 conv_id None 无刷新。 if let Some(cid) = cb_conv_id {