class SidekiqUtils::Middleware::Server::AdditionalSerialization
Public Instance Methods
call(worker, job, queue) { || ... }
click to toggle source
# File lib/sidekiq_utils/middleware/server/additional_serialization.rb, line 5 def call(worker, job, queue) if job['class'] == "ActiveJob::QueueAdapters::SidekiqAdapter::JobWrapper" # this is handled in ActiveJob, as it would otherwise raise an # exception before it even gets here return yield end job['args'] = job['args'].map do |arg| ::SidekiqUtils::AdditionalSerialization.unwrap_argument(arg) end yield end