app/jobs/enqueued_jobs.rb


1
2
3
4
5
6
7
8
9
10
11
12

module EnqueuedJobs
  def enqueued_jobs(argument = nil)
    if argument
      condition = " AND args->>0 = '#{argument}'"
    else
      condition = ""
    end
    
    Que.execute("SELECT * FROM que_jobs WHERE job_class = '#{name}'#{condition}")
  end
end