Advertisement
Guest User

Untitled

a guest
May 4th, 2016
58
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.62 KB | None | 0 0
  1. def self.reserve(worker, max_run_time = Worker.max_run_time) # rubocop:disable CyclomaticComplexity
  2. # scope to filter to records that are "ready to run"
  3. ready_scope = ready_to_run(worker.name, max_run_time)
  4.  
  5. # scope to filter to the single next eligible job
  6. ready_scope = ready_scope.where("priority >= ?", Worker.min_priority) if Worker.min_priority
  7. ready_scope = ready_scope.where("priority <= ?", Worker.max_priority) if Worker.max_priority
  8. ready_scope = ready_scope.where(queue: Worker.queues) if Worker.queues.any?
  9. ready_scope = ready_scope.by_priority
  10.  
  11. reserve_with_scope(ready_scope, worker, db_time_now)
  12. end
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement