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

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

.clear_locks!(worker_name) ⇒ Object

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

[View source]

38
39
40
 
# File 'lib/delayed/backend/active_record.rb', line 38

def self.clear_locks!(worker_name)
  update_all("locked_by = null, locked_at = null", ["locked_by = ?", worker_name])
end