diff --git a/app/controllers/content_controller.rb b/app/controllers/content_controller.rb index 8719a65b..a951998a 100644 --- a/app/controllers/content_controller.rb +++ b/app/controllers/content_controller.rb @@ -21,7 +21,7 @@ def export_csv @recipient = current_user.email start_time_string = Time.zone.now.to_s - CsvExportWorker.perform_async(search_params.stringify_keys, @recipient, start_time_string) + CsvExportJob.perform_async(search_params.stringify_keys, @recipient, start_time_string) end private diff --git a/app/workers/csv_export_worker.rb b/app/sidekiq/csv_export_job.rb similarity index 93% rename from app/workers/csv_export_worker.rb rename to app/sidekiq/csv_export_job.rb index 6c5a7d8b..a0cf688a 100644 --- a/app/workers/csv_export_worker.rb +++ b/app/sidekiq/csv_export_job.rb @@ -1,9 +1,9 @@ require "prometheus/client" require "prometheus/client/push" -class CsvExportWorker +class CsvExportJob include FileStorage - include Sidekiq::Worker + include Sidekiq::Job sidekiq_options retry: 0 sidekiq_options queue: "export_csv" @@ -61,3 +61,5 @@ def push_metrics_to_pushgateway(elapsed_time_seconds) ).add(prometheus_registry) end end + +CsvExportWorker = CsvExportJob ## TODO: Remove once queued jobs at the time of the upgrade are complete diff --git a/spec/workers/concerns/file_storage_spec.rb b/spec/sidekiq/concerns/file_storage_spec.rb similarity index 100% rename from spec/workers/concerns/file_storage_spec.rb rename to spec/sidekiq/concerns/file_storage_spec.rb diff --git a/spec/workers/csv_export_worker_spec.rb b/spec/sidekiq/csv_export_job_spec.rb similarity index 98% rename from spec/workers/csv_export_worker_spec.rb rename to spec/sidekiq/csv_export_job_spec.rb index 58e57426..ac284db1 100644 --- a/spec/workers/csv_export_worker_spec.rb +++ b/spec/sidekiq/csv_export_job_spec.rb @@ -1,6 +1,6 @@ require "govuk_sidekiq/testing" -RSpec.describe CsvExportWorker do +RSpec.describe CsvExportJob do let(:search_params) do { date_range: "past-30-days", @@ -68,7 +68,7 @@ let(:csv_export_histogram) { instance_spy(Prometheus::Client::Histogram) } before do - Sidekiq::Worker.clear_all + Sidekiq::Job.clear_all ENV["AWS_CSV_EXPORT_BUCKET_NAME"] = "test-bucket" ENV["PROMETHEUS_PUSHGATEWAY_URL"] = "http://prometheus-pushgateway.local"