Method: Delayed::Backend::MongoMapper::Job.clear_locks!

Defined in:: lib/delayed/backend/mongo_mapper.rb

.clear_locks!(worker_name) ⇒ `Object`

When a worker is exiting, make sure we don’t have any locked jobs.



74
75
76

# File 'lib/delayed/backend/mongo_mapper.rb', line 74

def self.clear_locks!(worker_name)
  collection.update({:locked_by => worker_name}, {"$set" => {:locked_at => nil, :locked_by => nil}}, :multi => true)
end