Sha256: 0e6005d8513656580b49e68be27aaf71bbcf93bf02fed26ef87b19459feb3b4b
Contents?: true
Size: 636 Bytes
Versions: 53
Compression:
Stored size: 636 Bytes
Contents
module Dynflow
module DelayedExecutors
class Polling < Abstract
def core_class
Dynflow::DelayedExecutors::PollingCore
end
end
class PollingCore < AbstractCore
attr_reader :poll_interval
def configure(options)
super(options)
@poll_interval = options[:poll_interval]
end
def start
check_delayed_plans
end
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
end
end
end
Version data entries
53 entries across 53 versions & 1 rubygems