Method: Delayed::Backend::DataMapper::Job.clear_locks!
- Defined in:
- lib/delayed/backend/data_mapper.rb
.clear_locks!(worker_name) ⇒ Object
When a worker is exiting, make sure we don’t have any locked jobs.
65 66 67 |
# File 'lib/delayed/backend/data_mapper.rb', line 65 def self.clear_locks!(worker_name) all(:locked_by => worker_name).update(:locked_at => nil, :locked_by => nil) end |