diff options
| -rw-r--r-- | app/jobs/enqueued_jobs.rb | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/app/jobs/enqueued_jobs.rb b/app/jobs/enqueued_jobs.rb index 7372ceb..116af98 100644 --- a/app/jobs/enqueued_jobs.rb +++ b/app/jobs/enqueued_jobs.rb @@ -22,8 +22,6 @@ module EnqueuedJobs def enqueued_jobs(argument = nil) condition = argument ? " AND args->>0 = '#{argument}'" : '' - Que.execute( - "SELECT * FROM que_jobs WHERE job_class = '#{name}'#{condition}" - ) + QueJob.where("job_class = '#{name}'#{condition}") end end |