pub struct FlowValue {Show 25 fields
pub modules: Vec<FlowModule>,
pub failure_module: Option<Box<FlowModule>>,
pub preprocessor_module: Option<Box<FlowModule>>,
pub same_worker: Option<bool>,
pub preserve_step_tags: Option<bool>,
pub concurrent_limit: Option<f64>,
pub concurrency_key: Option<String>,
pub concurrency_time_window_s: Option<f64>,
pub on_concurrency_limit: Option<OnConcurrencyLimit>,
pub debounce_delay_s: Option<i32>,
pub debounce_key: Option<String>,
pub debounce_args_to_accumulate: Option<Vec<String>>,
pub max_total_debouncing_time: Option<i32>,
pub max_total_debounces_amount: Option<i32>,
pub skip_expr: Option<String>,
pub cache_ttl: Option<f64>,
pub cache_ignore_s3_path: Option<bool>,
pub delete_after_secs: Option<i32>,
pub timeout: Option<i32>,
pub flow_env: Option<HashMap<String, Value>>,
pub priority: Option<f64>,
pub early_return: Option<String>,
pub chat_input_enabled: Option<bool>,
pub notes: Option<Vec<FlowNote>>,
pub groups: Option<Vec<FlowGroup>>,
}Expand description
FlowValue : The flow structure containing modules and optional preprocessor/failure handlers
Fields§
§modules: Vec<FlowModule>Array of steps that execute in sequence. Each step can be a script, subflow, loop, or branch
failure_module: Option<Box<FlowModule>>§preprocessor_module: Option<Box<FlowModule>>§same_worker: Option<bool>If true, all steps run on the same worker for better performance
If true and the flow runs on a custom worker tag, steps that declare their own non-empty tag run on it instead of inheriting the flow tag. Steps without their own tag still inherit the flow tag.
concurrent_limit: Option<f64>Maximum number of concurrent executions of this flow
concurrency_key: Option<String>Expression to group concurrent executions (e.g., by user ID)
concurrency_time_window_s: Option<f64>Time window in seconds for concurrent_limit
on_concurrency_limit: Option<OnConcurrencyLimit>What a run of this flow does when its concurrency limit is reached. queue (default) re-queues it to a later slot, fail ends it immediately as failed, like any failed step.
debounce_delay_s: Option<i32>Delay in seconds to debounce flow executions
debounce_key: Option<String>Expression to group debounced executions
debounce_args_to_accumulate: Option<Vec<String>>Arguments to accumulate across debounced executions
max_total_debouncing_time: Option<i32>Maximum total time in seconds that a job can be debounced
max_total_debounces_amount: Option<i32>Maximum number of times a job can be debounced
skip_expr: Option<String>JavaScript expression to conditionally skip the entire flow
cache_ttl: Option<f64>Cache duration in seconds for flow results
cache_ignore_s3_path: Option<bool>§delete_after_secs: Option<i32>If set, delete the flow job’s args, result and logs after this many seconds following job completion
timeout: Option<i32>Wall-clock limit in seconds for the whole flow run, counted from its start and including time spent sleeping or suspended at an approval. It also applies when the flow is called as a subflow step, unless that step sets its own timeout, which replaces it. It is checked periodically, so a run can go a few seconds past it. When it expires, the running steps are cancelled, the failure module runs if there is one, and the flow ends cancelled with a timeout error. A calling flow sees the subflow step fail with that error.
flow_env: Option<HashMap<String, Value>>Environment variables available to all steps. Values can be strings, JSON values, or special references: ‘$var:path’ (workspace variable) or ‘$res:path’ (resource).
priority: Option<f64>Execution priority (higher numbers run first)
early_return: Option<String>Id of the step whose result a sync webhook returns as soon as that step completes, while the rest of the flow keeps running. When the step does not run, or fails while the flow has a failure module, the flow’s final result is returned instead.
chat_input_enabled: Option<bool>Whether this flow accepts chat-style input
notes: Option<Vec<FlowNote>>Sticky notes attached to the flow
groups: Option<Vec<FlowGroup>>Semantic groups of modules for organizational purposes