Contents

class PeakFlowUtils::SidekiqParametersLogging < PeakFlowUtils::ApplicationService
  def perform
    require "sidekiq"
    require "sidekiq/processor"

    Sidekiq::Processor.class_eval do
      def execute_job(worker, cloned_args)
        PeakFlowUtils::Notifier.with_parameters(sidekiq: {worker_class_name: worker.class.name, cloned_args: cloned_args}) do
          worker.perform(*cloned_args)
        end
      end
    end

    succeed!
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
peak_flow_utils-0.1.19	app/services/peak_flow_utils/sidekiq_parameters_logging.rb
peak_flow_utils-0.1.18	app/services/peak_flow_utils/sidekiq_parameters_logging.rb
peak_flow_utils-0.1.17	app/services/peak_flow_utils/sidekiq_parameters_logging.rb