delayed_job_plugin.rb

class DelayedJobPlugin

  attr_reader :limiter, :dj

  def initialize(limiter_klass:, **opts)
    @limiter = limiter_klass.new(opts)
  end

  # Delayed::Worker вызовет new без агрументов у каждого плагина
  def new(*_args)
    configure_lifecycle(Delayed::Worker.lifecycle)
  end

  def configure_lifecycle lifecycle
    lifecycle.after(:perform) do |worker, *_args|
      worker.stop if limiter.check
    end
  end

end