Module: Julewire::ActiveJob::JobExecution

Defined in:
lib/julewire/active_job/job_execution.rb

Class Method Summary collapse

Class Method Details

.call(job, configuration: Configuration.new) ⇒ Object 



9
10
11
12
13
14
15
16
 
# File 'lib/julewire/active_job/job_execution.rb', line 9

def call(job, configuration: Configuration.new, &)
  carrier = carrier_for(job)
  return perform_job(job, configuration, &) unless configuration.propagation?

  Julewire::Core::Propagation::Carrier.restore(carrier, key: configuration.carrier_key) do
    perform_job(job, configuration, &)
  end
end