summaryrefslogtreecommitdiff
path: root/app/workers/object_pool
diff options
context:
space:
mode:
Diffstat (limited to 'app/workers/object_pool')
-rw-r--r--app/workers/object_pool/create_worker.rb4
-rw-r--r--app/workers/object_pool/destroy_worker.rb2
-rw-r--r--app/workers/object_pool/join_worker.rb2
-rw-r--r--app/workers/object_pool/schedule_join_worker.rb2
4 files changed, 9 insertions, 1 deletions
diff --git a/app/workers/object_pool/create_worker.rb b/app/workers/object_pool/create_worker.rb
index cf87ad95077..586b81fcd30 100644
--- a/app/workers/object_pool/create_worker.rb
+++ b/app/workers/object_pool/create_worker.rb
@@ -3,6 +3,8 @@
module ObjectPool
class CreateWorker # rubocop:disable Scalability/IdempotentWorker
include ApplicationWorker
+
+ sidekiq_options retry: 3
include ObjectPoolQueue
include ExclusiveLeaseGuard
@@ -28,7 +30,7 @@ module ObjectPool
pool.create_object_pool
pool.mark_ready
- rescue => e
+ rescue StandardError => e
pool.mark_failed
raise e
end
diff --git a/app/workers/object_pool/destroy_worker.rb b/app/workers/object_pool/destroy_worker.rb
index d42cee59d03..297780b20bd 100644
--- a/app/workers/object_pool/destroy_worker.rb
+++ b/app/workers/object_pool/destroy_worker.rb
@@ -3,6 +3,8 @@
module ObjectPool
class DestroyWorker # rubocop:disable Scalability/IdempotentWorker
include ApplicationWorker
+
+ sidekiq_options retry: 3
include ObjectPoolQueue
def perform(pool_repository_id)
diff --git a/app/workers/object_pool/join_worker.rb b/app/workers/object_pool/join_worker.rb
index 8103c04b507..282a8f54695 100644
--- a/app/workers/object_pool/join_worker.rb
+++ b/app/workers/object_pool/join_worker.rb
@@ -3,6 +3,8 @@
module ObjectPool
class JoinWorker # rubocop:disable Scalability/IdempotentWorker
include ApplicationWorker
+
+ sidekiq_options retry: 3
include ObjectPoolQueue
worker_resource_boundary :cpu
diff --git a/app/workers/object_pool/schedule_join_worker.rb b/app/workers/object_pool/schedule_join_worker.rb
index c00bb2967f2..44208208d04 100644
--- a/app/workers/object_pool/schedule_join_worker.rb
+++ b/app/workers/object_pool/schedule_join_worker.rb
@@ -3,6 +3,8 @@
module ObjectPool
class ScheduleJoinWorker # rubocop:disable Scalability/IdempotentWorker
include ApplicationWorker
+
+ sidekiq_options retry: 3
include ObjectPoolQueue
def perform(pool_id)