Sha256: 8960bbf8edefc5c5b8253aa12771c234d2b3dd1d665b2e39944feb270a6b5ef8
Contents?: true
Size: 666 Bytes
Versions: 25
Compression:
Stored size: 666 Bytes
Contents
# frozen_string_literal: true
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
25 entries across 25 versions & 1 rubygems