Struct FunctionTask 

pub struct FunctionTask { /* private fields */ }

Task that wraps an async function for easy workflow definition.

Useful for simple workflows without custom task types.

Example

use forge_agent::workflow::tasks::FunctionTask;
use forge_agent::workflow::TaskId;

let task = FunctionTask::new(
    TaskId::new("my_task"),
    "My Task".to_string(),
    |ctx| async {
        // Do work here
        Ok(TaskResult::Success)
    }
);

Implementations

impl FunctionTask

pub fn new<F, Fut>(id: TaskId, name: String, f: F) -> Self

where F: Fn(&TaskContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<TaskResult, TaskError>> + Send + 'static,

Creates a new FunctionTask with the given ID, name, and async function.

Trait Implementations

impl WorkflowTask for FunctionTask

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