Struct TaskGroup 

pub struct TaskGroup {
    pub id: String,
    pub name: Option<String>,
    pub description: Option<String>,
    pub condition: Value,
    pub terminal: bool,
    /* private fields */
}

A contiguous run of tasks sharing one condition, and optionally ending the workflow once the run completes.

Groups are authored as nested objects inside a workflow’s tasks list — an element carrying a tasks key is a group, one carrying a function key is a Task. The parser flattens the tree into Workflow::tasks and records each group’s span on the task that opens it (Task::group_starts), so the executor keeps walking a flat slice.

The condition is evaluated once, on entry. A false result skips every task in the span; the individual tasks’ own conditions are not evaluated.

Example JSON Definition

{
    "id": "have_videos",
    "condition": {">": [{"length": [{"var": "temp_data.videos"}]}, 0]},
    "terminal": false,
    "tasks": [
        {"id": "rank", "name": "Rank", "function": {"name": "map", "input": {}}},
        {"id": "trim", "name": "Trim", "function": {"name": "map", "input": {}}}
    ]
}

Fields

id: String

Unique identifier for the group within the workflow. Shares the task id namespace, so a group cannot reuse a task’s id.

name: Option<String>

Human-readable name.

description: Option<String>

Optional description explaining what the group covers.

condition: Value

JSONLogic condition gating the whole span. Defaults to true.

terminal: bool

Whether reaching the end of this group ends the workflow.

Trait Implementations

impl Clone for TaskGroup

fn clone(&self) -> TaskGroup

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskGroup

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

Formats the value using the given formatter.