diff options
Diffstat (limited to 'app/workers/concerns/application_worker.rb')
-rw-r--r-- | app/workers/concerns/application_worker.rb | 19 |
1 files changed, 0 insertions, 19 deletions
diff --git a/app/workers/concerns/application_worker.rb b/app/workers/concerns/application_worker.rb index 83261d9e42e..c1fec4f0196 100644 --- a/app/workers/concerns/application_worker.rb +++ b/app/workers/concerns/application_worker.rb @@ -13,7 +13,6 @@ module ApplicationWorker include Gitlab::SidekiqVersioning::Worker LOGGING_EXTRA_KEY = 'extra' - DEFAULT_DELAY_INTERVAL = 1 SAFE_PUSH_BULK_LIMIT = 1000 included do @@ -92,18 +91,6 @@ module ApplicationWorker validate_worker_attributes! end - def perform_async(*args) - return super if Gitlab::Database::LoadBalancing.primary_only? - - # Worker execution for workers with data_consistency set to :delayed or :sticky - # will be delayed to give replication enough time to complete - if utilizes_load_balancing_capabilities? && Feature.disabled?(:skip_scheduling_workers_for_replicas, default_enabled: :yaml) - perform_in(delay_interval, *args) - else - super - end - end - def set_queue queue_name = ::Gitlab::SidekiqConfig::WorkerRouter.global.route(self) sidekiq_options queue: queue_name # rubocop:disable Cop/SidekiqOptionsQueue @@ -194,12 +181,6 @@ module ApplicationWorker end end - protected - - def delay_interval - DEFAULT_DELAY_INTERVAL.seconds - end - private def do_push_bulk(args_list) |