module Que::Scheduler::Audit
Constants
- ENQUEUED_TABLE_NAME
- INSERT_AUDIT
- INSERT_AUDIT_ENQUEUED
- TABLE_NAME
Public Class Methods
append(scheduler_job_id, executed_at, enqueued_jobs)
click to toggle source
# File lib/que/scheduler/audit.rb, line 26 def append(scheduler_job_id, executed_at, enqueued_jobs) ::Que::Scheduler::VersionSupport.execute(INSERT_AUDIT, [scheduler_job_id, executed_at]) enqueued_jobs.each do |j| inserted = ::Que::Scheduler::VersionSupport.execute( INSERT_AUDIT_ENQUEUED, [scheduler_job_id] + j.values_at(:job_class, :queue, :priority, :args, :job_id, :run_at) ) raise "Cannot save audit row #{scheduler_job_id} #{executed_at} #{j}" if inserted.empty? end end