Remove DelayedJobHelper
This commit is contained in:
parent
cfa5fb8b0f
commit
378d2fb44c
2 changed files with 0 additions and 29 deletions
|
@ -1,28 +0,0 @@
|
|||
# frozen_string_literal: true
|
||||
|
||||
# License: AGPL-3.0-or-later WITH Web-Template-Output-Additional-Permission-3.0-or-later
|
||||
require 'qx'
|
||||
require 'delayed_job'
|
||||
|
||||
module DelayedJobHelper
|
||||
# Create a serialized delayed job handler for use in inserting new delayed jobs with raw sql
|
||||
# Be sure to wrap the handler in double quotes when inserting, not single
|
||||
def self.create_handler(obj, method_name, args)
|
||||
Delayed::PerformableMethod.new(obj, method_name, args).to_yaml.to_s
|
||||
end
|
||||
|
||||
# Manually enqueue a job
|
||||
def self.enqueue_job(obj, method_name, args, options = {})
|
||||
handler = Delayed::PerformableMethod.new(obj, method_name, args).to_yaml.to_s
|
||||
Qx.insert_into(:delayed_jobs)
|
||||
.values(
|
||||
created_at: Time.current,
|
||||
updated_at: Time.current,
|
||||
priority: options[:priority] || 0,
|
||||
attempts: 0,
|
||||
handler: handler,
|
||||
run_at: options[:run_at] || Time.current,
|
||||
queue: options[:queue]
|
||||
).returning('*').execute
|
||||
end
|
||||
end
|
|
@ -4,7 +4,6 @@
|
|||
require 'insert/insert_donation'
|
||||
require 'insert/insert_supporter_notes'
|
||||
require 'timespan'
|
||||
require 'delayed_job_helper'
|
||||
|
||||
module PayRecurringDonation
|
||||
# Pay ALL recurring donations that are currently due; each payment gets a queued delayed_job
|
||||
|
|
Loading…
Reference in a new issue