Struct Task 

pub struct Task {
    pub id: String,
    pub name: String,
    pub description: Option<String>,
    pub condition: Value,
    pub condition_index: Option<usize>,
    pub function: FunctionConfig,
    pub continue_on_error: bool,
}

A single processing unit within a workflow.

Tasks execute functions with optional conditions and error handling. They are processed sequentially within a workflow, allowing later tasks to depend on results from earlier ones.

Example JSON Definition

{
    "id": "validate_user",
    "name": "Validate User Data",
    "description": "Ensures user data meets requirements",
    "condition": {"==": [{"var": "metadata.type"}, "user"]},
    "function": {
        "name": "validation",
        "input": { "rules": [...] }
    },
    "continue_on_error": false
}

Fields

id: String

Unique identifier for the task within the workflow.

name: String

Human-readable name for the task.

description: Option<String>

Optional description explaining what the task does.

condition: Value

JSONLogic condition that determines if the task should execute. Conditions can only access metadata fields, not data fields. Defaults to true (always execute).

condition_index: Option<usize>

Index into the compiled logic cache for this task’s condition. Set during workflow compilation; not serialized.

function: FunctionConfig

The function configuration specifying what operation to perform. Can be a built-in function (map, validation) or a custom function.

continue_on_error: bool

Whether to continue workflow execution if this task fails. When true, errors are recorded but don’t stop the workflow. Defaults to false.

Trait Implementations

impl Clone for Task

fn clone(&self) -> Task

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Task

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Task

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.