diff --git a/lib/active_job/job_batch_id.rb b/lib/active_job/job_batch_id.rb index 5810d152..fc6978a6 100644 --- a/lib/active_job/job_batch_id.rb +++ b/lib/active_job/job_batch_id.rb @@ -18,5 +18,9 @@ def deserialize(job_data) super self.batch_id = job_data['batch_id'] end + + def batch + @batch ||= SolidQueue::JobBatch.find_by(id: batch_id) + end end end