Sha256: 576acafeaa6c2f103888f3bb3c67bb6ebc6fe7ed92435d6a22ad7a15f350bed7
Contents?: true
Size: 1.12 KB
Versions: 33
Compression:
Stored size: 1.12 KB
Contents
module Cron
#
# Automatically update Product Version Lifecycle State to EOL If it is past it's EOL date
# Runs Daily
#
class TrimFailedDelayedJobs < TrimCollection
#
# Return the failed collection
#
def collection
Delayed::Backend::Mongoid::Job.where(:failed_at.exists => true)
end
def archive?(job)
if 'Delayed::PerformableMethod'.eql?(job.name)
data = { object: job.failed_object.inspect,
method: job.failed_method_name,
args: job.failed_args,
failed_at: job.failed_at,
attempts: job.attempts,
locked_by: job.locked_by }
SlackNotification.say(data, template: :failed_delayed_job)
true
else
false
end
rescue StandardError => error
log_error "Unable to determine if we should archive job: #{job}", error
false
end
#
# If the slack API is not present, don't delete jobs or we wont know about it.
#
def self.valid_environment?
SystemConfiguration.slack_api_url.present?
rescue StandardError
false
end
end
end
Version data entries
33 entries across 33 versions & 1 rubygems