From af3065d167d0f2a3eb55956af3634ba90b21bb44 Mon Sep 17 00:00:00 2001 From: Aaron Collier Date: Wed, 25 Jan 2023 09:37:03 -0800 Subject: [PATCH] Match queues to class name --- app/jobs/replication/delivery_dispatcher_job.rb | 2 +- app/jobs/replication/s3_east_delivery_job.rb | 2 +- app/jobs/replication/s3_west_delivery_job.rb | 2 +- spec/jobs/replication/s3_east_delivery_job_spec.rb | 2 +- spec/jobs/replication/s3_west_delivery_job_spec.rb | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/app/jobs/replication/delivery_dispatcher_job.rb b/app/jobs/replication/delivery_dispatcher_job.rb index b74998b49..d29a0d808 100644 --- a/app/jobs/replication/delivery_dispatcher_job.rb +++ b/app/jobs/replication/delivery_dispatcher_job.rb @@ -18,7 +18,7 @@ module Replication # the VM is updated to a new vesrion). Therefore, we receive the zip # metadata from the process that actually created the zip file. class DeliveryDispatcherJob < Replication::ZipPartJobBase - queue_as :replication_plexer + queue_as :replication_delivery_dispatcher before_enqueue do |job| job.zip_info_check!(job.arguments.fourth) diff --git a/app/jobs/replication/s3_east_delivery_job.rb b/app/jobs/replication/s3_east_delivery_job.rb index 32225264f..48ec04942 100644 --- a/app/jobs/replication/s3_east_delivery_job.rb +++ b/app/jobs/replication/s3_east_delivery_job.rb @@ -6,7 +6,7 @@ module Replication # Please update the configs for the various environments if it's renamed or moved. # @note This name is slightly misleading, as this class solely deals with AWS US East 1 endpoint class S3EastDeliveryJob < Replication::DeliveryJobBase - queue_as :replication_aws_us_east_1_delivery + queue_as :replication_s3_east_delivery # perform method is defined in DeliveryJobBase diff --git a/app/jobs/replication/s3_west_delivery_job.rb b/app/jobs/replication/s3_west_delivery_job.rb index b04159316..af110c276 100644 --- a/app/jobs/replication/s3_west_delivery_job.rb +++ b/app/jobs/replication/s3_west_delivery_job.rb @@ -6,7 +6,7 @@ module Replication # Please update the configs for the various environments if it's renamed or moved. # @note This name is slightly misleading, as this class solely deals with AWS US West 2 endpoint class S3WestDeliveryJob < Replication::DeliveryJobBase - queue_as :replication_aws_us_west_2_delivery + queue_as :replication_s3_west_delivery # perform method is defined in DeliveryJobBase diff --git a/spec/jobs/replication/s3_east_delivery_job_spec.rb b/spec/jobs/replication/s3_east_delivery_job_spec.rb index 72bfe5920..0e2ff4867 100644 --- a/spec/jobs/replication/s3_east_delivery_job_spec.rb +++ b/spec/jobs/replication/s3_east_delivery_job_spec.rb @@ -8,6 +8,6 @@ end it 'uses its own queue' do - expect(described_class.new.queue_name).to eq 'replication_aws_us_east_1_delivery' + expect(described_class.new.queue_name).to eq 'replication_s3_east_delivery' end end diff --git a/spec/jobs/replication/s3_west_delivery_job_spec.rb b/spec/jobs/replication/s3_west_delivery_job_spec.rb index 1bb1bdf7f..f50e1ca6b 100644 --- a/spec/jobs/replication/s3_west_delivery_job_spec.rb +++ b/spec/jobs/replication/s3_west_delivery_job_spec.rb @@ -8,6 +8,6 @@ end it 'uses its own queue' do - expect(described_class.new.queue_name).to eq 'replication_aws_us_west_2_delivery' + expect(described_class.new.queue_name).to eq 'replication_s3_west_delivery' end end