Sha256: 60d003be0523d8883b80283ee9e8f4d1c2771c9cbe95ed90cda6e905c2e4f86d
Contents?: true
Size: 1.46 KB
Versions: 8
Compression:
Stored size: 1.46 KB
Contents
# frozen_string_literal: true
module SidekiqUniqueJobs
class TimeoutCalculator
def self.for_item(item)
new(item)
end
def initialize(item)
@item = item
end
def time_until_scheduled
scheduled = item[AT_KEY]
return 0 unless scheduled
(Time.at(scheduled) - Time.now.utc).to_i
end
def seconds
raise NotImplementedError
end
def worker_class_queue_lock_expiration
worker_class_expiration_for QUEUE_LOCK_TIMEOUT_KEY
end
def worker_class_run_lock_expiration
worker_class_expiration_for RUN_LOCK_TIMEOUT_KEY
end
def worker_class
@worker_class ||= SidekiqUniqueJobs.worker_class_constantize(item[CLASS_KEY])
end
private
def worker_class_expiration_for(key)
return unless worker_class.respond_to?(:get_sidekiq_options)
worker_class.get_sidekiq_options[key]
end
attr_reader :item
end
class RunLockTimeoutCalculator < TimeoutCalculator
def seconds
@seconds ||= (
worker_class_run_lock_expiration ||
SidekiqUniqueJobs.config.default_run_lock_expiration
).to_i
end
end
class QueueLockTimeoutCalculator < TimeoutCalculator
def seconds
queue_lock_expiration + time_until_scheduled
end
def queue_lock_expiration
@queue_lock_expiration ||=
(
worker_class_queue_lock_expiration ||
SidekiqUniqueJobs.config.default_queue_lock_expiration
).to_i
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems