Propagate RequestStore contents across a Delayed Job boundary

request_store_plugin.rb

class RequestStorePlugin < ::Delayed::Plugin
  callbacks do |lifecycle|
    lifecycle.before(:enqueue) do |job|
      obj = job.payload_object
      obj.instance_variable_set(:@_request_store, RequestStore.store)
      job.payload_object = obj # reserialize the job
    end

    lifecycle.before(:perform) do |worker, job, &block|
      request_store = YAML.load(job.handler).instance_variable_get(:@_request_store) || {}
      request_store.each do |k, v|
        RequestStore.store[k] = v
      end
    end
  end
end