Skip to main content
What this builds. A main pipeline that splits a newline-delimited input into a list via SplitTextNode, then runs a sub-pipeline once per element by setting execution_mode="batch" on the PipelineNode. You’ll end up with. A saved batched-pipeline whose output is the sub-pipeline’s output_0 produced for each split line. 
import vectorshift

from vectorshift import Pipeline
from vectorshift.pipeline import InputNode, OutputNode, PipelineNode, SplitTextNode

vectorshift.api_key = 'your api key '


sub_pipeline = Pipeline.fetch(name="your sub pipeline")

print(sub_pipeline)

input_node = InputNode(node_name="input_0")

split_text_node = SplitTextNode(
    node_name="split_text_node", text=input_node.text, delimiter="newline"
)

pipeline_node = PipelineNode(
    pipeline_id=sub_pipeline.id,
    node_name="sub_pipeline",
    input_0=split_text_node.processed_text,
    execution_mode="batch",
)

output_node = OutputNode(node_name="output_0", value=pipeline_node.output_0)

PIPELINE_NAME = "batched-pipeline"
try:
    main_pipeline = Pipeline.fetch(name=PIPELINE_NAME)
    print(
        f"Pipeline fetched: id={main_pipeline.id}, branch_id={main_pipeline.branch_id}"
    )
except Exception as e:
    print(f"Error fetching pipeline: {e}")
    main_pipeline = Pipeline.new(
        name=PIPELINE_NAME,
        nodes=[input_node, split_text_node, pipeline_node, output_node],
    )
    print(
        f"Pipeline created: id={main_pipeline.id}, branch_id={main_pipeline.branch_id}"
    )

​
Expected output

<Pipeline ...>
Pipeline created: id=..., branch_id=...
execution_mode="batch" is what tells the runtime to fan the sub-pipeline out across the list — without it, the node receives the list as a single input.

​
See also

Sub-pipelines

Single-shot sub-pipeline composition.

Batch config

Batch mode on individual LLM nodes.

Pipeline reference

Full method surface.