Add two schedulers' test
This commit is contained in:
parent
33d454fff5
commit
3be796adf8
4 changed files with 28 additions and 2 deletions
|
@ -3,7 +3,7 @@
|
|||
class Scheduler::SidekiqHealthScheduler
|
||||
include Sidekiq::Worker
|
||||
|
||||
sidekiq_options retry: 0
|
||||
sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 15.seconds.to_i
|
||||
|
||||
def perform
|
||||
url = ENV.fetch('SIDEKIQ_HEALTH_FETCH_URL', nil)
|
||||
|
|
|
@ -3,7 +3,7 @@
|
|||
class Scheduler::UpdateInstanceInfoScheduler
|
||||
include Sidekiq::Worker
|
||||
|
||||
sidekiq_options retry: 1
|
||||
sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i
|
||||
|
||||
def perform
|
||||
Instance.select(:domain).reorder(nil).find_in_batches do |instances|
|
||||
|
|
13
spec/workers/scheduler/sidekiq_health_scheduler_spec.rb
Normal file
13
spec/workers/scheduler/sidekiq_health_scheduler_spec.rb
Normal file
|
@ -0,0 +1,13 @@
|
|||
# frozen_string_literal: true
|
||||
|
||||
require 'rails_helper'
|
||||
|
||||
describe Scheduler::SidekiqHealthScheduler do
|
||||
let(:worker) { described_class.new }
|
||||
|
||||
describe 'perform' do
|
||||
it 'runs without error' do
|
||||
expect { worker.perform }.to_not raise_error
|
||||
end
|
||||
end
|
||||
end
|
|
@ -0,0 +1,13 @@
|
|||
# frozen_string_literal: true
|
||||
|
||||
require 'rails_helper'
|
||||
|
||||
describe Scheduler::UpdateInstanceInfoScheduler do
|
||||
let(:worker) { described_class.new }
|
||||
|
||||
describe 'perform' do
|
||||
it 'runs without error' do
|
||||
expect { worker.perform }.to_not raise_error
|
||||
end
|
||||
end
|
||||
end
|
Loading…
Add table
Add a link
Reference in a new issue