diff --git a/lib/active_job/queue_adapters/solid_queue_ext.rb b/lib/active_job/queue_adapters/solid_queue_ext.rb index a7e5b66e..ff62faab 100644 --- a/lib/active_job/queue_adapters/solid_queue_ext.rb +++ b/lib/active_job/queue_adapters/solid_queue_ext.rb @@ -169,7 +169,7 @@ def count end def find_job(active_job_id) - if job = SolidQueue::Job.find_by(active_job_id: active_job_id) + if job = SolidQueue::Job.where(active_job_id: active_job_id).order(:id).last job if matches_relation_filters?(job) end end