Method: EQ::Queueing::Backends::Sequel#pop

Defined in:
lib/eq-queueing/backends/sequel.rb

#pop(id) ⇒ TrueClass, FalseClass

finishes a job in the working queue

Parameters:

  • id (Fixnum) —

    of the job

Returns:

  • (TrueClass, FalseClass) —

    true, when there was a job that could be deleted



58
59
60
61
62
 
# File 'lib/eq-queueing/backends/sequel.rb', line 58

def pop id
  jobs.where(id: id).delete == 1
rescue ::Sequel::DatabaseError => e
  retry if on_error e
end