Sha256: 26a625315b8e1b97af5d578ae1a4d3a4f064835b0a7dd51699a53fd4c7a27a0f
Contents?: true
Size: 1.86 KB
Versions: 37
Compression:
Stored size: 1.86 KB
Contents
$worker_test_count = 0
$worker_success = false
class TestPlainJob
def self.queue; "test-plain"; end
def self.perform(x, y); $worker_test_count += x + y + 1; end
end
class TestJob
include Backburner::Queue
queue_priority :medium
queue_respond_timeout 300
def self.perform(x, y); $worker_test_count += x + y; end
end
class TestSlowJob
include Backburner::Queue
queue_priority :medium
queue_respond_timeout 300
def self.perform(x, y); sleep 1; $worker_test_count += x + y; end
end
class TestStuckJob
include Backburner::Queue
queue_priority :medium
queue_respond_timeout 300
def self.perform(_x, _y)
loop do
sleep 0.5
end
end
end
class TestFailJob
include Backburner::Queue
def self.perform(x, y); raise RuntimeError; end
end
class TestRetryJob
include Backburner::Queue
def self.perform(x, y)
$worker_test_count += 1
raise RuntimeError unless $worker_test_count > 2
$worker_success = true
end
end
class TestConfigurableRetryJob
include Backburner::Queue
def self.perform(retry_count)
$worker_test_count += 1
raise RuntimeError unless $worker_test_count > retry_count
$worker_success = true
end
end
class TestRetryWithQueueOverridesJob
include Backburner::Queue
def self.perform(retry_count)
$worker_test_count += 1
raise RuntimeError unless $worker_test_count > retry_count
$worker_success = true
end
def self.queue_max_job_retries
3
end
def self.queue_retry_delay
0
end
def self.queue_retry_delay_proc
lambda { |min_retry_delay, num_retries| min_retry_delay + (num_retries ** 2) }
end
end
class TestAsyncJob
include Backburner::Performable
def self.foo(x, y); $worker_test_count = x * y; end
end
class TestLambdaQueueJob
include Backburner::Queue
queue lambda { |klass| klass.calculated_queue_name }
def self.calculated_queue_name; 'lambda-queue' end
end
Version data entries
37 entries across 37 versions & 2 rubygems