123456789101112131415161718192021 |
- class ActiveJobLock < ApplicationModel
- def of?(active_job)
- active_job.job_id == active_job_id
- end
- def peform_pending?
- updated_at == created_at
- end
- def transfer_to(active_job)
- logger.info "Transferring ActiveJobLock with id '#{id}' from active_job_id '#{active_job_id}' to active_job_id '#{active_job_id}'."
- reset_time_stamp = Time.zone.now
- update!(
- active_job_id: active_job.job_id,
- created_at: reset_time_stamp,
- updated_at: reset_time_stamp
- )
- end
- end
|