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