Method: Worker::Queue#clean_locks

Defined in:

lib/worker/queue.rb

#clean_locks ⇒ Object

cleans locked by jobs that have been dormant for a while

# File 'lib/worker/queue.rb', line 58

def clean_locks
  db[:worker_jobs].where('locked_at < ?', Time.now - max_job_time).update(locked_by: nil)
end