Skip to main content
What this builds. A whirlwind tour of the version-management surface on Pipeline: save(bump=...), revert(version=...), move_to_folder(...), and remove_node(...). You’ll end up with. Two new minor versions on the fetched pipeline, the pipeline reverted to an earlier version, moved to a folder, and a node removed. 
from vectorshift.pipeline import Pipeline, BumpLevel

# Create a pipeline to demonstrate version management
# pipeline = Pipeline.new(name="revert_manage_example_12345")
# inp = pipeline.add(name="input_0", id="input_0").input(input_type="string")
# out = pipeline.add(name="output_0", id="output_0").output(
#     output_type="string", value=inp.text
# )
# pipeline.save(deploy=True)

pipeline = Pipeline.fetch(name="revert_manage_example_12345")

print("PIPELINE CREATED")

# Save new versions with bumps
pipeline.save(bump=BumpLevel.MINOR, description="version 0.1.0")
pipeline.save(bump=BumpLevel.MINOR, description="version 0.2.0")

print("VERSIONS SAVED")

# Revert to an earlier version
result = pipeline.revert(version="0.6.2")
print(f"REVERTED TO VERSION 0.1.0: {result}")

# Move to a folder (replace with a real folder ID)
result = pipeline.move_to_folder(folder_id="69c28367535a2a4abd668606")
print(f"Move: {result}")

# # Remove a node by name
result = pipeline.remove_node(node_name="output_0")
# print(f"Remove node: {result}")

​
Expected output

PIPELINE CREATED
VERSIONS SAVED
REVERTED TO VERSION 0.1.0: {...}
Move: {...}
The folder id and version string here are placeholders — substitute your own. The commented-out Pipeline.new(...) block at the top is the bootstrap you’d run the first time.

​
See also

Share and publish

Share with users/orgs and publish to the marketplace.

Terminate a run

Cancel an in-flight execution.

Pipeline reference

Full method surface.