class Bellbro::SidekiqUtils::Job

Attributes

source[RW]

Public Class Methods

all_for_class(klass_name) click to toggle source
# File lib/bellbro/sidekiq_utils.rb, line 45
def self.all_for_class(klass_name)
  Retryable.retryable(on: Redis::TimeoutError) do
    Queue.all.map do |q|
      q.map do |job|
        next unless job.klass == klass_name
        new(job)
      end
    end.flatten.compact
  end
end
new(source) click to toggle source
# File lib/bellbro/sidekiq_utils.rb, line 33
def initialize(source)
  @source = source
end

Public Instance Methods

jid() click to toggle source
# File lib/bellbro/sidekiq_utils.rb, line 41
def jid
  source.jid
end
method_missing(method_name, *args, &block) click to toggle source
# File lib/bellbro/sidekiq_utils.rb, line 37
def method_missing(method_name, *args, &block)
  source.args.first.try(:[], method_name.to_s)
end