diff --git a/app/workers/scheduler/sidekiq_health_scheduler.rb b/app/workers/scheduler/sidekiq_health_scheduler.rb index 657537b8f8..646976d831 100644 --- a/app/workers/scheduler/sidekiq_health_scheduler.rb +++ b/app/workers/scheduler/sidekiq_health_scheduler.rb @@ -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) diff --git a/app/workers/scheduler/update_instance_info_scheduler.rb b/app/workers/scheduler/update_instance_info_scheduler.rb index e4d1230a78..0587146b32 100644 --- a/app/workers/scheduler/update_instance_info_scheduler.rb +++ b/app/workers/scheduler/update_instance_info_scheduler.rb @@ -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| diff --git a/spec/workers/scheduler/sidekiq_health_scheduler_spec.rb b/spec/workers/scheduler/sidekiq_health_scheduler_spec.rb new file mode 100644 index 0000000000..899b09fee3 --- /dev/null +++ b/spec/workers/scheduler/sidekiq_health_scheduler_spec.rb @@ -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 diff --git a/spec/workers/scheduler/update_instance_info_scheduler_spec.rb b/spec/workers/scheduler/update_instance_info_scheduler_spec.rb new file mode 100644 index 0000000000..17c2ee0ca6 --- /dev/null +++ b/spec/workers/scheduler/update_instance_info_scheduler_spec.rb @@ -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