diff --git a/app/controllers/moderator/bulk_reverts_controller.rb b/app/controllers/moderator/bulk_reverts_controller.rb index 78629b7fa..d441bd892 100644 --- a/app/controllers/moderator/bulk_reverts_controller.rb +++ b/app/controllers/moderator/bulk_reverts_controller.rb @@ -15,7 +15,7 @@ module Moderator @bulk_revert.preview render action: "new" else - @bulk_revert.delay(:queue => "default", :priority => 15).process(CurrentUser.user, @constraints) + ProcessBulkRevertJob.perform_later(CurrentUser.user, @constraints) flash[:notice] = "Reverts queued" redirect_to new_moderator_bulk_revert_path end diff --git a/app/jobs/process_bulk_revert_job.rb b/app/jobs/process_bulk_revert_job.rb new file mode 100644 index 000000000..8aa5387ca --- /dev/null +++ b/app/jobs/process_bulk_revert_job.rb @@ -0,0 +1,8 @@ +class ProcessBulkRevertJob < ApplicationJob + queue_as :default + queue_with_priority 20 + + def perform(creator, constraints) + BulkRevert.new.process(creator, constraints) + end +end