Struct WorkflowBuilder 

pub struct WorkflowBuilder { /* private fields */ }

Fluent builder for constructing workflows.

WorkflowBuilder provides a chainable API for creating workflows with multiple tasks and dependencies between them.

Example

use forge_agent::workflow::{WorkflowBuilder, MockTask, TaskId};

let workflow = WorkflowBuilder::new()
    .add_task(Box::new(MockTask::new("a", "Task A")))
    .add_task(Box::new(MockTask::new("b", "Task B")))
    .add_task(Box::new(MockTask::new("c", "Task C")))
    .dependency(TaskId::new("a"), TaskId::new("b"))
    .dependency(TaskId::new("b"), TaskId::new("c"))
    .build()
    .unwrap();

Implementations

impl WorkflowBuilder

pub fn new() -> Self

Creates a new WorkflowBuilder.

pub fn with_auto_detect(self, forge: &Forge) -> Self

Configures the builder with a Forge instance for auto-detection.

Arguments

• forge - Forge instance for graph-based dependency detection

Returns

Self for method chaining

Example

let builder = WorkflowBuilder::new()
    .with_auto_detect(&forge)
    .add_task(Box::new(GraphQueryTask::find_symbol("main")));

pub fn add_task(self, task: Box<dyn WorkflowTask>) -> Self

Adds a task to the workflow.

Arguments

• task - Boxed trait object implementing WorkflowTask

Returns

Self for method chaining

Example

let builder = WorkflowBuilder::new()
    .add_task(Box::new(MockTask::new("task-1", "First Task")));

pub fn dependency(self, from: TaskId, to: TaskId) -> Self

Adds a dependency between two tasks.

Creates a directed edge from from to to, indicating that to depends on from (from must execute first).

Arguments

• from - Task ID of the prerequisite (executes first)
• to - Task ID of the dependent (executes after)

Returns

Self for method chaining

Note

Dependencies are validated when build is called. Invalid dependencies (cycles, missing tasks) will cause build to fail.

Example

let builder = WorkflowBuilder::new()
    .add_task(Box::new(MockTask::new("a", "Task A")))
    .add_task(Box::new(MockTask::new("b", "Task B")))
    .dependency(TaskId::new("a"), TaskId::new("b"));

pub fn build(self) -> Result<Workflow, WorkflowError>

Builds the workflow from configured tasks and dependencies.

Returns

• Ok(Workflow) - If workflow is valid
• Err(WorkflowError) - If validation fails (cycles, missing tasks, empty)

Errors

• WorkflowError::EmptyWorkflow - No tasks were added
• WorkflowError::CycleDetected - Dependencies contain a cycle
• WorkflowError::TaskNotFound - Dependency references non-existent task

Example

let workflow = WorkflowBuilder::new()
    .add_task(Box::new(MockTask::new("task-1", "Task")))
    .build()
    .unwrap();

pub async fn build_auto_detect(self) -> Result<Workflow, WorkflowError>

Builds the workflow with automatic dependency detection.

This method builds the workflow, runs dependency detection using the stored Forge instance, applies high-confidence suggestions, and validates the completed workflow.

Returns

• Ok(Workflow) - Valid workflow with auto-detected dependencies
• Err(WorkflowError) - If validation fails or no Forge configured

Errors

• WorkflowError::EmptyWorkflow - No tasks were added
• WorkflowError::CycleDetected - Auto-detection created a cycle
• WorkflowError::TaskNotFound - Dependency references non-existent task

Example

let workflow = WorkflowBuilder::new()
    .with_auto_detect(&forge)
    .add_task(Box::new(GraphQueryTask::find_symbol("process_data")))
    .add_task(Box::new(GraphQueryTask::references("process_data")))
    .build_auto_detect()
    .await?;

pub fn sequential( tasks: Vec<Box<dyn WorkflowTask>>, ) -> Result<Workflow, WorkflowError>

Creates a sequential workflow from a list of tasks.

Tasks are executed in the order provided, with each task depending on the previous task.

Arguments

• tasks - Vector of boxed trait objects in execution order

Returns

• Ok(Workflow) - If workflow is valid
• Err(WorkflowError) - If tasks vector is empty

Example

let workflow = WorkflowBuilder::sequential(vec![
    Box::new(MockTask::new("step-1", "Step 1")),
    Box::new(MockTask::new("step-2", "Step 2")),
    Box::new(MockTask::new("step-3", "Step 3")),
]).unwrap();

Trait Implementations

impl Default for WorkflowBuilder

fn default() -> Self

Returns the “default value” for a type.