Struct ConditionalTask 

pub struct ConditionalTask { /* private fields */ }

Task that executes conditionally based on another task’s result.

The condition task is executed first, then based on its result, either the then_task or else_task is executed.

Implementations

impl ConditionalTask

pub fn new( condition_task: Box<dyn WorkflowTask>, then_task: Box<dyn WorkflowTask>, else_task: Option<Box<dyn WorkflowTask>>, ) -> Self

Creates a new conditional task.

Arguments

• condition_task - Task whose result determines the branch
• then_task - Task executed on success
• else_task - Optional task executed on failure

Example

let condition = Box::new(FunctionTask::new(
    TaskId::new("check"),
    "Check".to_string(),
    |_ctx| async { Ok(TaskResult::Success) }
));
let then_branch = Box::new(FunctionTask::new(
    TaskId::new("then"),
    "Then".to_string(),
    |_ctx| async { Ok(TaskResult::Success) }
));
let task = ConditionalTask::new(condition, then_branch, None);

pub fn with_else( condition_task: Box<dyn WorkflowTask>, then_task: Box<dyn WorkflowTask>, else_task: Box<dyn WorkflowTask>, ) -> Self

Creates a conditional task with an else branch.

Trait Implementations

impl WorkflowTask for ConditionalTask

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, context: &'life1 TaskContext, ) -> Pin<Box<dyn Future<Output = Result<TaskResult, TaskError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executes the task with the provided context.

fn id(&self) -> TaskId

Returns the unique task identifier.

fn name(&self) -> &str

Returns the human-readable task name.

fn dependencies(&self) -> Vec<TaskId>

Returns the list of task dependencies.

fn compensation(&self) -> Option<CompensationAction>

Returns the compensation action for this task (if any).