Struct TaskDef 

pub struct TaskDef {
    pub name: String,
    pub task_fn: Box<dyn FnMut(&TaskContext) -> Result<TaskOutput, FabricError>>,
    pub resource_req: ResourceReq,
    pub inputs: Vec<DataRef>,
    pub outputs: Vec<DataRef>,
    pub retries: u32,
}

Definition of a task within the graph.

The task_fn closure uses FnMut so it can be retried on failure. For tasks with retries > 0, the closure is called again with the same TaskContext on each retry attempt.

Fields

name: String

Human-readable task name.

task_fn: Box<dyn FnMut(&TaskContext) -> Result<TaskOutput, FabricError>>

The function to execute. Called with a TaskContext on each attempt (initial + retries).

resource_req: ResourceReq

Resource requirements.

inputs: Vec<DataRef>

Named data inputs this task consumes.

outputs: Vec<DataRef>

Named data outputs this task produces.

retries: u32

Number of retry attempts on failure (0 = no retries).