Sha256: 6b140774b29aa2d491ed9ce5423d15db8bc2bea3c1c06da7743ca90ffca58400

Contents?: true

Size: 508 Bytes

Versions: 5

Compression:

Stored size: 508 Bytes

Contents

# frozen_string_literal: true

module Delayed
  module Master
    class Worker
      module Plugins
        class ExecutorWrapper < Delayed::Plugin
          callbacks do |lifecycle|
            lifecycle.around(:thread) do |worker, &block|
              if defined?(Rails)
                Rails.application.executor.wrap do
                  block.call
                end
              else
                block.call
              end
            end
          end
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
delayed_job_master-3.1.2 lib/delayed/master/worker/plugins/executor_wrapper.rb
delayed_job_master-3.1.1 lib/delayed/master/worker/plugins/executor_wrapper.rb
delayed_job_master-3.1.0 lib/delayed/master/worker/plugins/executor_wrapper.rb
delayed_job_master-3.0.1 lib/delayed/master/worker/plugins/executor_wrapper.rb
delayed_job_master-3.0.0 lib/delayed/master/worker/plugins/executor_wrapper.rb