Struct FlowModule 

pub struct FlowModule {

    pub id: String,
    pub value: Box<FlowModuleValue>,
    pub stop_after_if: Option<Box<StopAfterIf>>,
    pub stop_after_all_iters_if: Option<Box<StopAfterIf>>,
    pub skip_if: Option<Box<FlowModuleSkipIf>>,
    pub sleep: Option<Box<InputTransform>>,
    pub cache_ttl: Option<f64>,
    pub cache_ignore_s3_path: Option<bool>,
    pub timeout: Option<Box<InputTransform>>,
    pub delete_after_secs: Option<i32>,
    pub summary: Option<String>,
    pub mock: Option<Box<FlowModuleMock>>,
    pub suspend: Option<Box<FlowModuleSuspend>>,
    pub priority: Option<f64>,
    pub continue_on_error: Option<bool>,
    pub job_token_scopes: Option<Option<Vec<String>>>,
    pub retry: Option<Box<Retry>>,
    pub debouncing: Option<Box<FlowModuleDebouncing>>,
}

FlowModule : A single step in a flow. Can be a script, subflow, loop, or branch

Fields

id: String

Unique identifier for this step. Used to reference results via ‘results.step_id’. Must be a valid identifier (alphanumeric, underscore, hyphen)

value: Box<FlowModuleValue>

stop_after_if: Option<Box<StopAfterIf>>

stop_after_all_iters_if: Option<Box<StopAfterIf>>

skip_if: Option<Box<FlowModuleSkipIf>>

sleep: Option<Box<InputTransform>>

cache_ttl: Option<f64>

Cache duration in seconds for this step’s results

cache_ignore_s3_path: Option<bool>

timeout: Option<Box<InputTransform>>

delete_after_secs: Option<i32>

If set, delete the step’s args, result and logs after this many seconds following job completion

summary: Option<String>

Short description of what this step does

mock: Option<Box<FlowModuleMock>>

suspend: Option<Box<FlowModuleSuspend>>

priority: Option<f64>

Execution priority for this step (higher numbers run first)

continue_on_error: Option<bool>

If true, flow continues even if this step fails

job_token_scopes: Option<Option<Vec<String>>>

Scopes the token of this step’s jobs is restricted to (domain:action[:resource], e.g. oidc:write), on top of the flow’s own restriction: a step can only narrow it. Applies to everything the step runs (loop and branch bodies, AI agent tools).

retry: Option<Box<Retry>>

debouncing: Option<Box<FlowModuleDebouncing>>

Implementations

impl FlowModule

pub fn new(id: String, value: FlowModuleValue) -> FlowModule

A single step in a flow. Can be a script, subflow, loop, or branch

Trait Implementations

impl Clone for FlowModule

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FlowModule

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

Formats the value using the given formatter.

impl Default for FlowModule

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for FlowModule

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for FlowModule

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for FlowModule

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for FlowModule