Pipelines

Build composable processing workflows with the Pipeline class.

from gdtest_nav_icons import Pipeline, transform

pipe = Pipeline("clean")
pipe.add_stage(lambda d: [x for x in d if x > 0])
pipe.add_stage(lambda d: transform(d, scale=0.01))
result = pipe.run([-5, 10, 20, -3, 15])

Pipeline Inspection

len(pipe)   # number of stages
repr(pipe)  # Pipeline('clean', stages=2)