#NEWLINE# def run( engine_options ) : #NEWLINE# #INDENT# reporter = EventReporter ( ) #NEWLINE# reporter . notifier . register ( ANY , event_receiver ) #NEWLINE# flow = lf . Flow ( 'event-reporter' ) . add ( reporter ) #NEWLINE# eng = engines . load ( flow , engine = 'worker-based' , ** engine_options ) #NEWLINE# eng . run ( )