Note
Click here to download the full example code
Add additional tasks to your pipelines¶
Our Example Pipeline¶
don’t pay too much attention to this, we’re just creating a random meaningless pipeline
pipeline = ip.Pipeline({
'a': ip.Input(0),
'b': ip.Input(1),
('a_plus_1','b_plus_1') : (add1, 'a', 'b'),
('a_minus_1','b_minus_1') : (subtract1, 'a', 'b'),
}
)
Just call the pipeline’s update function¶
more_tasks = {
'average_a': (average,'a_plus_1','a_minus_1'),
'average_b': (average,'b_plus_1','b_minus_1'),
}
pipeline.update(more_tasks)