class Object
Public Instance Methods
delete_jobs_query(scope)
click to toggle source
# File lib/que/web/sql.rb, line 32 def delete_jobs_query(scope) <<-SQL.freeze WITH target AS (#{scope}) DELETE FROM que_jobs USING target WHERE target.locked AND target.id = que_jobs.id RETURNING pg_advisory_unlock(target.id) SQL end
reschedule_all_jobs_query(scope)
click to toggle source
# File lib/que/web/sql.rb, line 19 def reschedule_all_jobs_query(scope) <<-SQL.freeze WITH target AS (#{scope}) UPDATE que_jobs SET run_at = $1::timestamptz, expired_at = NULL FROM target WHERE target.locked AND target.id = que_jobs.id RETURNING pg_advisory_unlock(target.id) SQL end