module BusinessFlow # Include me to fire ActiveSupport notifications on the flow, every step, # and for any errors that happen. module Instrument def self.included(klass) klass.extend(ClassMethods) klass.step_executor ::BusinessFlow::InstrumentedExecutor end # Contains methods that we add to the DSL module ClassMethods def instrument_steps step_executor ::BusinessFlow::InstrumentedStepExecutor end end end end