Method: Mode::Connector::Scheduler#initialize

Defined in:
lib/mode/connector/scheduler.rb

#initialize(data_sources, options = {}) ⇒ Scheduler

Returns a new instance of Scheduler.



10
11
12
13
14
 
# File 'lib/mode/connector/scheduler.rb', line 10

def initialize(data_sources, options = {})
  @data_sources = data_sources
  @scheduler    = Rufus::Scheduler.new
  @max_jobs     = (options[:max_jobs] || 4).to_i
end