Commit 9b37811e authored by Heinrich Lee Yu's avatar Heinrich Lee Yu

Merge branch 'mk/tweak-sidekiq-retries-of-geo-jobs' into 'master'

Geo: Tweak sidekiq retries of some Geo jobs

See merge request gitlab-org/gitlab!71419
parents 6d7569d3 f1c1d2fa
...@@ -8,7 +8,7 @@ module Geo ...@@ -8,7 +8,7 @@ module Geo
include GeoQueue include GeoQueue
include Gitlab::Geo::LogHelpers include Gitlab::Geo::LogHelpers
sidekiq_options retry: 3, dead: false sidekiq_options retry: 1, dead: false
sidekiq_retry_in { |count| 30 * count } sidekiq_retry_in { |count| 30 * count }
......
...@@ -8,7 +8,7 @@ module Geo ...@@ -8,7 +8,7 @@ module Geo
include GeoQueue include GeoQueue
include Gitlab::Geo::LogHelpers include Gitlab::Geo::LogHelpers
sidekiq_options retry: 3, dead: false sidekiq_options retry: 1, dead: false
sidekiq_retry_in { |count| 30 * count } sidekiq_retry_in { |count| 30 * count }
......
...@@ -6,7 +6,6 @@ module Geo ...@@ -6,7 +6,6 @@ module Geo
data_consistency :always data_consistency :always
sidekiq_options retry: 3
include GeoQueue include GeoQueue
loggable_arguments 1, 2 loggable_arguments 1, 2
......
...@@ -6,7 +6,6 @@ module Geo ...@@ -6,7 +6,6 @@ module Geo
data_consistency :always data_consistency :always
sidekiq_options retry: 3
include GeoQueue include GeoQueue
loggable_arguments 1, 2, 2 loggable_arguments 1, 2, 2
......
...@@ -8,7 +8,7 @@ module Geo ...@@ -8,7 +8,7 @@ module Geo
include GeoQueue include GeoQueue
include Gitlab::Geo::LogHelpers include Gitlab::Geo::LogHelpers
sidekiq_options retry: 3, dead: false sidekiq_options retry: 1, dead: false
sidekiq_retry_in { |count| 30 * count } sidekiq_retry_in { |count| 30 * count }
......
...@@ -6,7 +6,6 @@ module Geo ...@@ -6,7 +6,6 @@ module Geo
data_consistency :always data_consistency :always
sidekiq_options retry: 3
include ExclusiveLeaseGuard include ExclusiveLeaseGuard
include GeoQueue include GeoQueue
include Gitlab::Geo::LogHelpers include Gitlab::Geo::LogHelpers
......
...@@ -4,7 +4,6 @@ module Geo ...@@ -4,7 +4,6 @@ module Geo
module RepositoryVerification module RepositoryVerification
module Primary module Primary
class ShardWorker < Geo::Scheduler::Primary::SchedulerWorker # rubocop:disable Scalability/IdempotentWorker class ShardWorker < Geo::Scheduler::Primary::SchedulerWorker # rubocop:disable Scalability/IdempotentWorker
sidekiq_options retry: false
loggable_arguments 0 loggable_arguments 0
attr_accessor :shard_name attr_accessor :shard_name
......
...@@ -6,7 +6,7 @@ module Geo ...@@ -6,7 +6,7 @@ module Geo
data_consistency :always data_consistency :always
sidekiq_options retry: 3 sidekiq_options retry: false
include GeoQueue include GeoQueue
include LimitedCapacity::Worker include LimitedCapacity::Worker
include ::Gitlab::Geo::LogHelpers include ::Gitlab::Geo::LogHelpers
......
...@@ -7,7 +7,7 @@ module Geo ...@@ -7,7 +7,7 @@ module Geo
data_consistency :always data_consistency :always
sidekiq_options retry: 3 sidekiq_options retry: false
include GeoQueue include GeoQueue
include ExclusiveLeaseGuard include ExclusiveLeaseGuard
include ::Gitlab::Geo::LogHelpers include ::Gitlab::Geo::LogHelpers
......
...@@ -12,7 +12,7 @@ module Geo ...@@ -12,7 +12,7 @@ module Geo
include CronjobQueue # rubocop:disable Scalability/CronWorkerContext include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
idempotent! idempotent!
sidekiq_options retry: false, dead: false sidekiq_options retry: false
feature_category :geo_replication feature_category :geo_replication
def perform def perform
......
...@@ -6,7 +6,7 @@ module Geo ...@@ -6,7 +6,7 @@ module Geo
data_consistency :always data_consistency :always
sidekiq_options retry: 3 sidekiq_options retry: false
include GeoQueue include GeoQueue
include LimitedCapacity::Worker include LimitedCapacity::Worker
include ::Gitlab::Geo::LogHelpers include ::Gitlab::Geo::LogHelpers
......
...@@ -10,7 +10,7 @@ module Geo ...@@ -10,7 +10,7 @@ module Geo
include ::Gitlab::Geo::LogHelpers include ::Gitlab::Geo::LogHelpers
idempotent! idempotent!
sidekiq_options retry: false, dead: false sidekiq_options retry: false
loggable_arguments 0 loggable_arguments 0
def perform(replicable_name) def perform(replicable_name)
......
...@@ -236,28 +236,25 @@ RSpec.describe 'Every Sidekiq worker' do ...@@ -236,28 +236,25 @@ RSpec.describe 'Every Sidekiq worker' do
'FlushCounterIncrementsWorker' => 3, 'FlushCounterIncrementsWorker' => 3,
'Geo::Batch::ProjectRegistrySchedulerWorker' => 3, 'Geo::Batch::ProjectRegistrySchedulerWorker' => 3,
'Geo::Batch::ProjectRegistryWorker' => 3, 'Geo::Batch::ProjectRegistryWorker' => 3,
'Geo::ContainerRepositorySyncWorker' => 3, 'Geo::ContainerRepositorySyncWorker' => 1,
'Geo::DesignRepositoryShardSyncWorker' => false, 'Geo::DesignRepositoryShardSyncWorker' => false,
'Geo::DesignRepositorySyncWorker' => 3, 'Geo::DesignRepositorySyncWorker' => 1,
'Geo::DestroyWorker' => 3, 'Geo::DestroyWorker' => 3,
'Geo::EventWorker' => 3, 'Geo::EventWorker' => 3,
'Geo::FileDownloadWorker' => 3, 'Geo::FileDownloadWorker' => 3,
'Geo::FileRegistryRemovalWorker' => 3, 'Geo::FileRegistryRemovalWorker' => 3,
'Geo::FileRemovalWorker' => 3, 'Geo::FileRemovalWorker' => 3,
'Geo::HashedStorageAttachmentsMigrationWorker' => 3, 'Geo::ProjectSyncWorker' => 1,
'Geo::HashedStorageMigrationWorker' => 3,
'Geo::ProjectSyncWorker' => 3,
'Geo::RenameRepositoryWorker' => 3, 'Geo::RenameRepositoryWorker' => 3,
'Geo::RepositoriesCleanUpWorker' => 3,
'Geo::RepositoryCleanupWorker' => 3, 'Geo::RepositoryCleanupWorker' => 3,
'Geo::RepositoryShardSyncWorker' => false, 'Geo::RepositoryShardSyncWorker' => false,
'Geo::RepositoryVerification::Primary::ShardWorker' => false, 'Geo::RepositoryVerification::Primary::ShardWorker' => false,
'Geo::RepositoryVerification::Primary::SingleWorker' => false, 'Geo::RepositoryVerification::Primary::SingleWorker' => false,
'Geo::RepositoryVerification::Secondary::SingleWorker' => false, 'Geo::RepositoryVerification::Secondary::SingleWorker' => false,
'Geo::ReverificationBatchWorker' => 0, 'Geo::ReverificationBatchWorker' => 0,
'Geo::Scheduler::Primary::SchedulerWorker' => 3, 'Geo::Scheduler::Primary::SchedulerWorker' => false,
'Geo::Scheduler::SchedulerWorker' => 3, 'Geo::Scheduler::SchedulerWorker' => false,
'Geo::Scheduler::Secondary::SchedulerWorker' => 3, 'Geo::Scheduler::Secondary::SchedulerWorker' => false,
'Geo::VerificationBatchWorker' => 0, 'Geo::VerificationBatchWorker' => 0,
'Geo::VerificationStateBackfillWorker' => false, 'Geo::VerificationStateBackfillWorker' => false,
'Geo::VerificationTimeoutWorker' => false, 'Geo::VerificationTimeoutWorker' => false,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment