清理: 注释去设计任务编号前缀改描述性表述
This commit is contained in:
@@ -1,6 +1,6 @@
|
|||||||
//! 工作流 DAG 上下文注入 — 当会话关联工作流时,将活跃路径注入 system prompt
|
//! 工作流 DAG 上下文注入 — 当会话关联工作流时,将活跃路径注入 system prompt
|
||||||
//!
|
//!
|
||||||
//! T4 实现,完整链路(生产侧已接通):
|
//! 完整链路(生产侧已接通):
|
||||||
//! - 生产:`run_workflow_inner`(workflow.rs)AI 路径(conv_id Some)启动时调
|
//! - 生产:`run_workflow_inner`(workflow.rs)AI 路径(conv_id Some)启动时调
|
||||||
//! `build_dag_summary` 产出摘要写入 `PerConvState.workflow_dag_summary`
|
//! `build_dag_summary` 产出摘要写入 `PerConvState.workflow_dag_summary`
|
||||||
//! (`workflow_id` 存本次执行 ID,非模板 ID);执行闭包终态(completed/failed)
|
//! (`workflow_id` 存本次执行 ID,非模板 ID);执行闭包终态(completed/failed)
|
||||||
|
|||||||
@@ -1143,7 +1143,7 @@ pub(crate) struct ToolCallDraft {
|
|||||||
/// 不在此推进任务状态 —— workflow.rs::run_workflow 内部已按 task_id+target_status 自动联动
|
/// 不在此推进任务状态 —— workflow.rs::run_workflow 内部已按 task_id+target_status 自动联动
|
||||||
/// (成功推进到 target / 失败按 regression_target 退回),此处不重复。
|
/// (成功推进到 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。
|
/// 启动写 workflow_id/workflow_dag_summary、终态回写摘要,供 agentic loop 注入 system prompt。
|
||||||
pub(crate) async fn execute_run_workflow_for_tool(
|
pub(crate) async fn execute_run_workflow_for_tool(
|
||||||
app: &tauri::AppHandle,
|
app: &tauri::AppHandle,
|
||||||
|
|||||||
@@ -120,7 +120,7 @@ pub async fn run_workflow(
|
|||||||
/// - execute_run_workflow_for_tool(AI 工具经 ai_approve 审批后执行)传 "ai"
|
/// - execute_run_workflow_for_tool(AI 工具经 ai_approve 审批后执行)传 "ai"
|
||||||
/// 原硬编码 "manual" 致 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 注入;
|
/// workflow_dag_summary 进会话状态,供 agentic loop 每轮 build_runtime_prompt 注入;
|
||||||
/// 执行闭包终态(completed/failed)回写终态摘要。会话不存在则静默跳过。
|
/// 执行闭包终态(completed/failed)回写终态摘要。会话不存在则静默跳过。
|
||||||
/// 命令层手动触发无会话上下文,传 None 零关联。
|
/// 命令层手动触发无会话上下文,传 None 零关联。
|
||||||
@@ -169,7 +169,7 @@ pub async fn run_workflow_inner(
|
|||||||
// 3. 写入执行记录(status=running)
|
// 3. 写入执行记录(status=running)
|
||||||
let execution_id: ExecutionId = new_id().into();
|
let execution_id: ExecutionId = new_id().into();
|
||||||
let dag_json = serde_json::to_string(&dag).map_err(err_str)?;
|
let dag_json = serde_json::to_string(&dag).map_err(err_str)?;
|
||||||
// T4: DAG 摘要启动态(无当前节点),启动写入与终态刷新共用同一基础文本,
|
// DAG 摘要启动态(无当前节点),启动写入与终态刷新共用同一基础文本,
|
||||||
// 闭包外算好 move 进闭包,闭包内只拼状态行不重算。
|
// 闭包外算好 move 进闭包,闭包内只拼状态行不重算。
|
||||||
let dag_summary = build_dag_summary(&dag, None);
|
let dag_summary = build_dag_summary(&dag, None);
|
||||||
let conv_id = conv_id.map(|s| s.to_string());
|
let conv_id = conv_id.map(|s| s.to_string());
|
||||||
@@ -192,7 +192,7 @@ pub async fn run_workflow_inner(
|
|||||||
.await
|
.await
|
||||||
.map_err(err_str)?;
|
.map_err(err_str)?;
|
||||||
|
|
||||||
// T4 生产侧:AI 路径启动时把执行 ID 与 DAG 摘要写入会话状态,接通
|
// 生产侧接线:AI 路径启动时把执行 ID 与 DAG 摘要写入会话状态,接通
|
||||||
// 「生产者 → workflow_dag_summary → build_runtime_prompt 注入」链路。
|
// 「生产者 → workflow_dag_summary → build_runtime_prompt 注入」链路。
|
||||||
// 存的是本次执行 ID(非模板 ID);会话不存在(已删除/无效 conv_id)静默跳过,
|
// 存的是本次执行 ID(非模板 ID);会话不存在(已删除/无效 conv_id)静默跳过,
|
||||||
// 与消费侧 conv_read 短路语义一致(不惰性创建空会话)。
|
// 与消费侧 conv_read 短路语义一致(不惰性创建空会话)。
|
||||||
@@ -304,7 +304,7 @@ pub async fn run_workflow_inner(
|
|||||||
// F-260616-06 ②-2: move task_id / target_status 进闭包供完成/失败回调使用
|
// F-260616-06 ②-2: move task_id / target_status 进闭包供完成/失败回调使用
|
||||||
let cb_task_id = task_id.clone();
|
let cb_task_id = task_id.clone();
|
||||||
let cb_target_status = target_status.clone();
|
let cb_target_status = target_status.clone();
|
||||||
// T4 终态刷新物料:conv_id + 基础摘要 + 会话锁句柄 move 进执行闭包
|
// 终态刷新物料:conv_id + 基础摘要 + 会话锁句柄 move 进执行闭包
|
||||||
let cb_conv_id = conv_id.clone();
|
let cb_conv_id = conv_id.clone();
|
||||||
let cb_dag_summary = dag_summary.clone();
|
let cb_dag_summary = dag_summary.clone();
|
||||||
let ai_session = state.ai_session.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);
|
state_registry.lock().await.remove(&exec_id);
|
||||||
|
|
||||||
// failed_node 从状态机取首个失败/取消节点(R9⑪: 原 String::new() 空值),
|
// failed_node 从状态机取首个失败/取消节点(R9⑪: 原 String::new() 空值),
|
||||||
// 失败补发事件与 T4 会话终态摘要共用,提到分支外计算。
|
// 失败补发事件与会话终态摘要共用,提到分支外计算。
|
||||||
let failed_node = if error.is_some() {
|
let failed_node = if error.is_some() {
|
||||||
executor
|
executor
|
||||||
.state_machine()
|
.state_machine()
|
||||||
@@ -432,7 +432,7 @@ pub async fn run_workflow_inner(
|
|||||||
.await;
|
.await;
|
||||||
}
|
}
|
||||||
|
|
||||||
// T4 终态刷新:工作流终态后把完成/失败结论写回会话摘要,agentic loop
|
// 终态刷新:工作流终态后把完成/失败结论写回会话摘要,agentic loop
|
||||||
// 下一轮注入终态而非启动时的「完成: 待执行器上报」。
|
// 下一轮注入终态而非启动时的「完成: 待执行器上报」。
|
||||||
// 会话不存在(已删除)静默跳过;手动路径 conv_id None 无刷新。
|
// 会话不存在(已删除)静默跳过;手动路径 conv_id None 无刷新。
|
||||||
if let Some(cid) = cb_conv_id {
|
if let Some(cid) = cb_conv_id {
|
||||||
|
|||||||
Reference in New Issue
Block a user