diff options
| -rw-r--r-- | app/workers/cluster_creation_worker.rb | 2 | ||||
| -rw-r--r-- | app/workers/concerns/cluster_queue.rb | 10 | ||||
| -rw-r--r-- | app/workers/wait_for_cluster_creation_worker.rb | 2 | ||||
| -rw-r--r-- | config/sidekiq_queues.yml | 3 |
4 files changed, 13 insertions, 4 deletions
diff --git a/app/workers/cluster_creation_worker.rb b/app/workers/cluster_creation_worker.rb index 220519134b9..d4ca9029a91 100644 --- a/app/workers/cluster_creation_worker.rb +++ b/app/workers/cluster_creation_worker.rb @@ -1,6 +1,6 @@ class ClusterCreationWorker include Sidekiq::Worker - include DedicatedSidekiqQueue + include ClusterQueue def perform(cluster_id) Gcp::Cluster.find_by_id(cluster_id).try do |cluster| diff --git a/app/workers/concerns/cluster_queue.rb b/app/workers/concerns/cluster_queue.rb new file mode 100644 index 00000000000..736ae90303c --- /dev/null +++ b/app/workers/concerns/cluster_queue.rb @@ -0,0 +1,10 @@ +## +# Concern for setting Sidekiq settings for the various Gcp clusters workers. +# +module ClusterQueue + extend ActiveSupport::Concern + + included do + sidekiq_options queue: :manage_cluster + end +end diff --git a/app/workers/wait_for_cluster_creation_worker.rb b/app/workers/wait_for_cluster_creation_worker.rb index d1f9b4e07f4..3b9978e986a 100644 --- a/app/workers/wait_for_cluster_creation_worker.rb +++ b/app/workers/wait_for_cluster_creation_worker.rb @@ -1,6 +1,6 @@ class WaitForClusterCreationWorker include Sidekiq::Worker - include DedicatedSidekiqQueue + include ClusterQueue INITIAL_INTERVAL = 2.minutes EAGER_INTERVAL = 10.seconds diff --git a/config/sidekiq_queues.yml b/config/sidekiq_queues.yml index 1af90d0a361..c60a2baf940 100644 --- a/config/sidekiq_queues.yml +++ b/config/sidekiq_queues.yml @@ -62,5 +62,4 @@ - [update_user_activity, 1] - [propagate_service_template, 1] - [background_migration, 1] - - [cluster_creation, 1] - - [wait_for_cluster_creation, 1] + - [manage_cluster, 1] |