Clear job with que

clear-job-with-que.rb

class JobQueue
  def self.clear(job_class, *args)
    case
    when job_class == RepoSynchronizationJob
      user_id = args.first[:user_id]
      sql =  <<-"EOQ".strip_heredoc
        DELETE FROM que_jobs
        WHERE
          job_class = #{ActiveRecord::Base.connection.quote(job_class)}
        AND
          (args->0->>'user_id')::INT = #{ActiveRecord::Base.connection.quote(user_id)}
      EOQ

      ActiveRecord::Base.connection.execute(sql)
    end
  end
end