Skip to main content
What this builds. A purely-deterministic pipeline that joins an input string with a literal "hello", then truncates the combined text via TextFormatterNode. You’ll end up with. A re-saved pipeline (fetched by id) wired as input_1 → combine_1 → text_formatter_1 → output_1. 
from vectorshift.pipeline import (
    Pipeline,
    InputNode,
    OutputNode,
    CombineTextNode,
    TextFormatterNode,
)

pipeline = Pipeline.fetch(id="69849103125b17e4b74d10ef")
pipeline.nodes.clear()
pipeline.save()

input_node = InputNode(node_name="input_1", input_type="string")

combine_node = CombineTextNode(
    node_name="combine_1",
    text=[input_node.text, "hello"],
)

text_formatter_node = TextFormatterNode(
    node_name="text_formatter_1",
    text=combine_node.processed_text,
    formatter="Truncate",
)

output_node = OutputNode(
    node_name="output_1",
    value=text_formatter_node.output,
)

pipeline.nodes = [input_node, combine_node, text_formatter_node, output_node]
pipeline.save()

​
Expected output

This script doesn’t print anything — success is signalled by the two pipeline.save() calls completing without an exception. Inspect the saved pipeline in the dashboard to verify the wiring.

​
See also

Create-list pipeline

Build a list inside a pipeline.

Read-JSON pipeline

Parse a JSON string and extract named keys.

Pipeline reference

Full method surface.