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