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