1 files changed, 3 insertions, 5 deletions
diff --git a/app/controllers/que_jobs_controller.rb b/app/controllers/que_jobs_controller.rb
index a458e9d..36d5558 100644
--- a/app/controllers/que_jobs_controller.rb
+++ b/app/controllers/que_jobs_controller.rb
@@ -20,9 +20,7 @@
 
 class QueJobsController < ApplicationController
   def cancel
-    ActiveRecord::Base.connection.execute(
-      "DELETE FROM que_jobs WHERE job_id = #{job_id}::bigint"
-    )
+    Que.execute :expire_job, [job_id]
 
     flash[:success] = 'Job canceled'
 
@@ -32,8 +30,8 @@ class QueJobsController < ApplicationController
   def retry_now
     ActiveRecord::Base.connection.execute(
       "UPDATE que_jobs
-       SET run_at      = now()
-       WHERE job_id    = #{job_id}::bigint"
+       SET run_at  = now()
+       WHERE id    = #{job_id}::bigint"
     )
 
     flash[:success] = 'Retrying the job now'