2020-01-08 14:57:17 +00:00
|
|
|
class ActiveJobLock < ActiveRecord::Base
|
2019-11-13 07:03:47 +00:00
|
|
|
|
|
|
|
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
|