Struct WorkflowBuilder 

pub struct WorkflowBuilder { /* private fields */ }

工作流构建器

Implementations

impl WorkflowBuilder

pub fn new(id: &str, name: &str) -> WorkflowBuilder

创建新的工作流构建器

pub fn description(self, desc: &str) -> WorkflowBuilder

设置描述

pub fn start(self) -> WorkflowBuilder

添加开始节点

pub fn start_with_id(self, id: &str) -> WorkflowBuilder

添加开始节点（自定义 ID）

pub fn end(self) -> WorkflowBuilder

添加结束节点

pub fn end_with_id(self, id: &str) -> WorkflowBuilder

添加结束节点（自定义 ID）

pub fn task<F, Fut>(self, id: &str, name: &str, executor: F) -> WorkflowBuilder

where F: Fn(WorkflowContext, WorkflowValue) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<WorkflowValue, String>> + Send + 'static,

添加任务节点

pub fn task_with_config<F, Fut>( self, id: &str, name: &str, executor: F, retry: RetryPolicy, timeout_ms: u64, ) -> WorkflowBuilder

where F: Fn(WorkflowContext, WorkflowValue) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<WorkflowValue, String>> + Send + 'static,

添加任务节点（带配置）

pub fn agent<F, Fut>(self, id: &str, name: &str, agent_fn: F) -> WorkflowBuilder

where F: Fn(WorkflowContext, WorkflowValue) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<WorkflowValue, String>> + Send + 'static,

添加智能体节点

pub fn llm_agent( self, id: &str, name: &str, agent: Arc<LLMAgent>, ) -> WorkflowBuilder

添加 LLM 智能体节点（使用 LLMAgent）

允许在工作流中使用预配置的 LLMAgent。

示例

let agent = LLMAgentBuilder::new()
    .with_id("my-agent")
    .with_provider(Arc::new(openai_from_env()?))
    .with_system_prompt("You are a helpful assistant.")
    .build()?;

let workflow = WorkflowBuilder::new("test", "Test")
    .start()
    .llm_agent("agent1", "LLM Agent", Arc::new(agent))
    .end()
    .build();

pub fn llm_agent_with_template( self, id: &str, name: &str, agent: Arc<LLMAgent>, prompt_template: String, ) -> WorkflowBuilder

添加 LLM 智能体节点（带 prompt 模板）

允许使用 Jinja-style 模板格式化输入。

示例

let workflow = WorkflowBuilder::new("test", "Test")
    .start()
    .llm_agent_with_template(
        "agent1",
        "LLM Agent",
        Arc::new(agent),
        "Process this data: {{ input }}".to_string()
    )
    .end()
    .build();

pub fn condition<F, Fut>( self, id: &str, name: &str, condition_fn: F, ) -> ConditionBuilder

where F: Fn(WorkflowContext, WorkflowValue) -> Fut + Send + Sync + 'static, Fut: Future<Output = bool> + Send + 'static,

添加条件节点

pub fn parallel(self, id: &str, name: &str) -> ParallelBuilder

添加并行节点

pub fn loop_node<F, Fut, C, CFut>( self, id: &str, name: &str, body: F, condition: C, max_iterations: u32, ) -> WorkflowBuilder

where F: Fn(WorkflowContext, WorkflowValue) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<WorkflowValue, String>> + Send + 'static, C: Fn(WorkflowContext, WorkflowValue) -> CFut + Send + Sync + 'static, CFut: Future<Output = bool> + Send + 'static,

添加循环节点

pub fn sub_workflow( self, id: &str, name: &str, sub_workflow_id: &str, ) -> WorkflowBuilder

添加子工作流节点

pub fn wait(self, id: &str, name: &str, event_type: &str) -> WorkflowBuilder

添加等待节点

pub fn transform<F, Fut>( self, id: &str, name: &str, transform_fn: F, ) -> WorkflowBuilder

where F: Fn(HashMap<String, WorkflowValue>) -> Fut + Send + Sync + 'static, Fut: Future<Output = WorkflowValue> + Send + 'static,

添加数据转换节点

pub fn node(self, node: WorkflowNode) -> WorkflowBuilder

添加自定义节点

pub fn edge(self, from: &str, to: &str) -> WorkflowBuilder

添加边（不改变当前节点）

pub fn conditional_edge( self, from: &str, to: &str, condition: &str, ) -> WorkflowBuilder

添加条件边

pub fn error_edge(self, from: &str, to: &str) -> WorkflowBuilder

添加错误处理边

pub fn goto(self, node_id: &str) -> WorkflowBuilder

跳转到指定节点（设置当前节点）

pub fn then(self, node_id: &str) -> WorkflowBuilder

从当前节点连接到指定节点

pub fn build(self) -> WorkflowGraph

构建工作流图

pub fn build_validated(self) -> Result<WorkflowGraph, Vec<String>>

验证并构建