core.transform.scatter
Transform a collection of items into parallel execution streams, where each item is processed independently.
Inputs
string | array[any]
required
The collection to scatter. Each item in the collection will be processed independently in its own execution stream. This should be a JSONPath expression to a collection or a list of items.
number | null
The interval in seconds between each scatter task.Default:
null.Examples
Fan out and collect resultscore.transform.gather
Collect the results of a list of execution streams into a single list.
Inputs
string
required
The JSONPath expression referencing the item to gather in the current execution stream.
boolean
Whether to drop null values from the final result. If True, any null values encountered during the gather operation will be omitted from the output list.Default:
false.string
Controls how errors are handled when gathering. “partition” puts successful results in
.result and errors in .error. “include” puts errors in .result as JSON objects. “drop” removes errors from .result. “raise” fails the gather if any branch errors.Default: "partition".Allowed values: partition, include, drop, raise.