Add option to limit clearing of jobs to specific class name(s)

Author: klenis

app/models/solid_queue/job/clearable.rb

@@ -6,13 +6,13 @@ module Clearable
       extend ActiveSupport::Concern
 
       included do
-        scope :clearable, ->(finished_before: SolidQueue.clear_finished_jobs_after.ago) { where.not(finished_at: nil).where(finished_at: ...finished_before) }
+        scope :clearable, ->(finished_before: SolidQueue.clear_finished_jobs_after.ago, class_name: nil) { where.not(finished_at: nil).where(finished_at: ...finished_before).where(class_name.present? ? { class_name: class_name } : {}) }
       end
 
       class_methods do
-        def clear_finished_in_batches(batch_size: 500, finished_before: SolidQueue.clear_finished_jobs_after.ago)
+        def clear_finished_in_batches(batch_size: 500, finished_before: SolidQueue.clear_finished_jobs_after.ago, class_name: nil)
           loop do
-            records_deleted = clearable(finished_before: finished_before).limit(batch_size).delete_all
+            records_deleted = clearable(finished_before: finished_before, class_name: class_name).limit(batch_size).delete_all
             break if records_deleted == 0
           end
         end

test/integration/jobs_lifecycle_test.rb

@@ -133,6 +133,21 @@ class JobsLifecycleTest < ActiveSupport::TestCase
       SolidQueue::Job.clear_finished_in_batches
     end
   end
+  
+  test "respect class name when clearing finished jobs" do
+    10.times { AddToBufferJob.perform_later(2) }
+    10.times { RaisingJob.perform_later(RuntimeError, "A") }
+    jobs = SolidQueue::Job.all
+
+    jobs.each(&:finished!)
+
+    travel_to 3.days.from_now
+
+    SolidQueue::Job.clear_finished_in_batches(class_name: "AddToBufferJob")
+
+    assert_equal 0, SolidQueue::Job.where(class_name: "AddToBufferJob").count
+    assert_equal 10, SolidQueue::Job.where(class_name: "RaisingJob").count
+  end
 
   private
     def deleting_finished_jobs