#defmodule ArithmeticPipeline do #use Opus.Pipeline #step :add_one #step :failing_atom, if: :run_failing_atom? #step :failing_tuple, if: :run_failing_tuple? #step :failing_exception, if: :run_failing_exception? #check :even?, if: :run_check_even? #step :square, with: &TestMath.square/1 #tee :publish_number, if: fn _ -> true end #step :double #link LinkedPipeline #link NonPipelineModule #end