class Que::Sequel::Model

Public Instance Methods

by_args(*args, **kwargs) click to toggle source
# File lib/que/sequel/model.rb, line 43
def by_args(*args, **kwargs)
  where(
    QUALIFIED_TABLE[:args].pg_jsonb.contains(JSON.dump(args)) &
    QUALIFIED_TABLE[:kwargs].pg_jsonb.contains(JSON.dump(kwargs))
  ) 
end
by_job_class(job_class) click to toggle source
# File lib/que/sequel/model.rb, line 26
def by_job_class(job_class)
  job_class = job_class.name if job_class.is_a?(Class)
  where(
    (QUALIFIED_TABLE[:job_class] =~ job_class) |
      (QUALIFIED_TABLE[:job_class] =~ "ActiveJob::QueueAdapters::QueAdapter::JobWrapper") &
      (QUALIFIED_TABLE[:args].pg_jsonb[0].get_text("job_class") =~ job_class)
  )
end
by_queue(queue) click to toggle source
# File lib/que/sequel/model.rb, line 35
def by_queue(queue)
  where(QUALIFIED_TABLE[:queue] => queue)
end
by_tag(tag) click to toggle source
# File lib/que/sequel/model.rb, line 39
def by_tag(tag)
  where(QUALIFIED_TABLE[:data].pg_jsonb.contains(JSON.dump(tags: [tag])))
end