Method: Airflow::Runner::BaseRunner#initialize

Defined in:
lib/async_flow/runner.rb

#initialize(definitions) ⇒ BaseRunner

Returns a new instance of BaseRunner.



31
32
33
34
35
36
 
# File 'lib/async_flow/runner.rb', line 31

def initialize(definitions)
  @poller = Poller.new(Persistence.workflow_runs)
  @executor = Executors::ThreadPoolExecutor.new(1)
  @definitions = definitions
  @mutex = Mutex.new
end