Sha256: 3f54ae0e11959c28d88a10dd5774fa1d6cb5f0a73558a722fa68ddd3fd499ae8
Contents?: true
Size: 1.71 KB
Versions: 11
Compression:
Stored size: 1.71 KB
Contents
NamedJob = Struct.new(:perform)
class NamedJob
def display_name
'named_job'
end
end
class SimpleJob
cattr_accessor(:runs) { 0 }
def perform
self.class.runs += 1
end
end
class NamedQueueJob < SimpleJob
def queue_name
'job_tracking'
end
end
class ErrorJob
cattr_accessor(:runs) { 0 }
def perform
raise StandardError, 'did not work'
end
end
class FailureJob < ErrorJob
def max_attempts
1
end
end
CustomRescheduleJob = Struct.new(:offset)
class CustomRescheduleJob
cattr_accessor(:runs) { 0 }
def perform
raise 'did not work'
end
def reschedule_at(time, _attempts)
time + offset
end
end
class LongRunningJob
def perform
sleep 250
end
end
class OnPermanentFailureJob < SimpleJob
attr_writer :raise_error
def initialize
@raise_error = false
end
def failure
raise 'did not work' if @raise_error
end
def max_attempts
1
end
end
module M
class ModuleJob
cattr_accessor(:runs) { 0 }
def perform
self.class.runs += 1
end
end
end
class CallbackJob
cattr_accessor :messages
def enqueue(_job)
self.class.messages << 'enqueue'
end
def before(_job)
self.class.messages << 'before'
end
def perform
self.class.messages << 'perform'
end
def after(_job)
self.class.messages << 'after'
end
def success(_job)
self.class.messages << 'success'
end
def error(_job, error)
self.class.messages << "error: #{error.class}"
end
def failure(_job)
self.class.messages << 'failure'
end
end
class EnqueueJobMod < SimpleJob
def enqueue(job)
job.run_at = 20.minutes.from_now
end
end
class ActiveJobJob < ActiveJob::Base # rubocop:disable Rails/ApplicationJob
def perform; end
end
Version data entries
11 entries across 11 versions & 1 rubygems