Struct TryCatchTask 

pub struct TryCatchTask { /* private fields */ }

Task that executes with error recovery.

The try_task is executed first. If it fails, the catch_task is executed instead, allowing the workflow to continue gracefully.

Implementations

impl TryCatchTask

pub fn new( try_task: Box<dyn WorkflowTask>, catch_task: Box<dyn WorkflowTask>, ) -> Self

Creates a new try-catch task.

Arguments

• try_task - Task to attempt
• catch_task - Task executed on try_task failure

Example

let try_task = Box::new(FunctionTask::new(
    TaskId::new("risky"),
    "Risky Operation".to_string(),
    |_ctx| async { Ok(TaskResult::Failed("error".to_string())) }
));
let catch_task = Box::new(FunctionTask::new(
    TaskId::new("recover"),
    "Recovery".to_string(),
    |_ctx| async { Ok(TaskResult::Success) }
));
let task = TryCatchTask::new(try_task, catch_task);

Trait Implementations

impl WorkflowTask for TryCatchTask

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).