class Dynflow::DelayedExecutors::PollingCore

Attributes

poll_interval[R]

Public Instance Methods

check_delayed_plans() click to toggle source
# File lib/dynflow/delayed_executors/polling.rb, line 23
def check_delayed_plans
  check_time = time
  plans = delayed_execution_plans(check_time)
  process plans, check_time

  world.clock.ping(self, poll_interval, :check_delayed_plans)
end
configure(options) click to toggle source
# File lib/dynflow/delayed_executors/polling.rb, line 14
def configure(options)
  super(options)
  @poll_interval = options[:poll_interval]
end
start() click to toggle source
# File lib/dynflow/delayed_executors/polling.rb, line 19
def start
  check_delayed_plans
end