Skip to contents

Getting started

Create a pipeline, add steps, run it, and collect results.

pip_new()
Create a pipeline
pip_add()
Add a step
pip_run()
Run a pipeline
pip_collect_out()
Collect step outputs
pipeflow pipeflow-package
pipeflow: Lightweight, General-Purpose Data Analysis Pipelines

Modify steps

Replace, rename, or remove steps; adjust tunable parameters.

pip_replace()
Replace a step
pip_rename()
Rename a step
pip_remove()
Remove a step
pip_set_params()
Set independent parameters

Pipeline composition

Combine, clone, or copy steps between pipelines.

pip_add_from()
Copy a step from another pipeline
pip_bind()
Bind pipelines
pip_clone()
Clone a pipeline

Inspection and views

Inspect the pipeline structure and create filtered views.

pip_get_graph()
Build pipeline graph data
pip_get_params()
Get independent parameters
pip_has_step()
Check whether a step exists
pip_view()
Create a pipeline view

Locking and tagging

Lock steps against changes or tag them for filtering.

pip_lock()
Lock selected steps against updates
pip_unlock()
Unlock selected steps
pip_tag()
Add tags to selected steps
pip_untag()
Remove tags from selected steps

S3 methods

Generic methods for pipeflow objects.

length(<pipeflow_pip>) length(<pipeflow_view>)
Length of a pipeflow pipeline or view
print(<pipeflow_pip>) print(<pipeflow_view>)
Print pipeflow objects
`[`(<pipeflow_pip>) `[[`(<pipeflow_pip>)
Extract or subset a pipeline
set_log_layout()
Set pipeflow log layout