Add lock expiration to Sidekiq workers

ecosyste-ms · Nov 22, 2024 · 7a6794d · 7a6794d
1 parent 788c50c
commit 7a6794d
Show file tree

Hide file tree

Showing 14 changed files with 14 additions and 14 deletions.
diff --git a/app/sidekiq/download_tags_worker.rb b/app/sidekiq/download_tags_worker.rb
@@ -1,6 +1,6 @@
 class DownloadTagsWorker
   include Sidekiq::Worker
-  sidekiq_options queue: 'tags', lock: :until_executed
+  sidekiq_options queue: 'tags', lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(repository_id)
     Repository.find_by_id(repository_id).try(:download_tags)

diff --git a/app/sidekiq/package_usage_sync_worker.rb b/app/sidekiq/package_usage_sync_worker.rb
@@ -1,6 +1,6 @@
 class PackageUsageSyncWorker
   include Sidekiq::Worker
-  sidekiq_options lock: :until_executed
+  sidekiq_options lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(package_usage_id)
     PackageUsage.find_by_id(package_usage_id).try(:sync)

diff --git a/app/sidekiq/parse_dependencies_worker.rb b/app/sidekiq/parse_dependencies_worker.rb
@@ -1,6 +1,6 @@
 class ParseDependenciesWorker
   include Sidekiq::Worker
-  sidekiq_options queue: 'dependencies', lock: :until_executed
+  sidekiq_options queue: 'dependencies', lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(repository_id)
     Repository.includes(manifests: :dependencies).find_by_id(repository_id).try(:parse_dependencies)

diff --git a/app/sidekiq/parse_tag_dependencies_worker.rb b/app/sidekiq/parse_tag_dependencies_worker.rb
@@ -1,6 +1,6 @@
 class ParseTagDependenciesWorker
   include Sidekiq::Worker
-  sidekiq_options queue: 'dependencies', lock: :until_executed
+  sidekiq_options queue: 'dependencies', lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(tag_id)
     Tag.includes(manifests: :dependencies).find_by_id(tag_id).try(:parse_dependencies)

diff --git a/app/sidekiq/ping_owner_worker.rb b/app/sidekiq/ping_owner_worker.rb
@@ -1,6 +1,6 @@
 class PingOwnerWorker
   include Sidekiq::Worker
-  sidekiq_options queue: :ping, lock: :until_executed
+  sidekiq_options queue: :ping, lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(host_name, full_name)
     host = Host.find_by_name(host_name)

diff --git a/app/sidekiq/ping_packages_worker.rb b/app/sidekiq/ping_packages_worker.rb
@@ -1,6 +1,6 @@
 class PingPackagesWorker
   include Sidekiq::Worker
-  sidekiq_options queue: :default, lock: :until_executed
+  sidekiq_options queue: :default, lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(repo_id)
     Repository.find_by_id(repo_id).try(:ping_packages)

diff --git a/app/sidekiq/ping_worker.rb b/app/sidekiq/ping_worker.rb
@@ -1,6 +1,6 @@
 class PingWorker
   include Sidekiq::Worker
-  sidekiq_options queue: :ping, lock: :until_executed
+  sidekiq_options queue: :ping, lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(host_name, full_name)
     host = Host.find_by_name(host_name)

diff --git a/app/sidekiq/repository_usage_worker.rb b/app/sidekiq/repository_usage_worker.rb
@@ -1,6 +1,6 @@
 class RepositoryUsageWorker
   include Sidekiq::Worker
-  sidekiq_options lock: :until_executed
+  sidekiq_options lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(repository_id)
     repository = Repository.find(repository_id)

diff --git a/app/sidekiq/sync_commit_stats_worker.rb b/app/sidekiq/sync_commit_stats_worker.rb
@@ -1,6 +1,6 @@
 class SyncCommitStatsWorker
   include Sidekiq::Worker
-  sidekiq_options lock: :until_executed
+  sidekiq_options lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(repository_id)
     Repository.find_by_id(repository_id).try(:sync_commit_stats)

diff --git a/app/sidekiq/sync_extra_details_worker.rb b/app/sidekiq/sync_extra_details_worker.rb
@@ -1,6 +1,6 @@
 class SyncExtraDetailsWorker
   include Sidekiq::Worker
-  sidekiq_options queue: 'extra', lock: :until_executed
+  sidekiq_options queue: 'extra', lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(repository_id)
     Repository.find_by_id(repository_id).try(:sync_extra_details)

diff --git a/app/sidekiq/sync_owner_worker.rb b/app/sidekiq/sync_owner_worker.rb
@@ -1,6 +1,6 @@
 class SyncOwnerWorker
   include Sidekiq::Worker
-  sidekiq_options lock: :until_executed
+  sidekiq_options lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(host_id, login)
     Host.find_by_id(host_id).try(:sync_owner, login)

diff --git a/app/sidekiq/sync_repository_worker.rb b/app/sidekiq/sync_repository_worker.rb
@@ -1,6 +1,6 @@
 class SyncRepositoryWorker
   include Sidekiq::Worker
-  sidekiq_options lock: :until_executed
+  sidekiq_options lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(host_id, full_name)
     Host.find_by_id(host_id).try(:sync_repository, full_name)

diff --git a/app/sidekiq/update_metadata_files_worker.rb b/app/sidekiq/update_metadata_files_worker.rb
@@ -1,6 +1,6 @@
 class UpdateMetadataFilesWorker
   include Sidekiq::Worker
-  sidekiq_options lock: :until_executed
+  sidekiq_options lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(repo_id)
     Repository.find_by_id(repo_id).try(:update_metadata_files)

diff --git a/app/sidekiq/update_repository_worker.rb b/app/sidekiq/update_repository_worker.rb
@@ -1,6 +1,6 @@
 class UpdateRepositoryWorker
   include Sidekiq::Worker
-  sidekiq_options lock: :until_executed
+  sidekiq_options lock: :until_executed, lock_expiration: 1.day.to_i
 
   def perform(repo_id)
     Repository.find_by_id(repo_id).try(:sync)