Class: Shikibu::Integrations::Sidekiq::TimerScheduler

Inherits:
Object
  • Object
show all
Includes:
Sidekiq::Job
Defined in:
lib/shikibu/integrations/sidekiq.rb

Overview

Scheduler for checking timers (run with sidekiq-scheduler or similar)

Instance Method Summary collapse

Instance Method Details

#perform ⇒ Object 



92
93
94
95
96
97
98
99
 
# File 'lib/shikibu/integrations/sidekiq.rb', line 92

def perform
  storage = Shikibu.app.storage
  expired = storage.find_expired_timers(limit: 100)

  expired.each do |timer|
    TimerWorker.perform_async(timer[:instance_id], timer[:timer_id])
  end
end