Top Level Namespace

Defined Under Namespace

Modules: Que

Instance Method Summary collapse

Instance Method Details

#delete_jobs_query(scope) ⇒ Object 



31
32
33
34
35
36
37
38
39
40
 
# File 'lib/que/web/sql.rb', line 31

def delete_jobs_query(scope)
  "    WITH target AS (\#{scope})\n    DELETE FROM que_jobs\n    USING target\n    WHERE target.locked\n    AND target.id = que_jobs.id\n    RETURNING pg_advisory_unlock(target.id)\n  SQL\nend\n".freeze

#reschedule_all_jobs_query(scope) ⇒ Object 



19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/que/web/sql.rb', line 19

def reschedule_all_jobs_query(scope)
  "    WITH target AS (\#{scope})\n    UPDATE que_jobs\n    SET run_at = $1::timestamptz\n    FROM target\n    WHERE target.locked\n    AND target.id = que_jobs.id\n    RETURNING pg_advisory_unlock(target.id)\n  SQL\nend\n".freeze