Method: Airflow::Runner::BaseRunner#run

Defined in:
lib/async_flow/runner.rb

#run(reactor) ⇒ Object

should already run parallel with the main worker



39
40
41
42
43
 
# File 'lib/async_flow/runner.rb', line 39

def run(reactor)
  logger.info "starting runner #{self}"
  running!
  _loop(reactor)
end