class Dynflow::ActiveJob::QueueAdapters::JobWrapper

Public Instance Methods

label() click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 36
def label
  input[:job_class]
end
plan(attributes) click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 26
def plan(attributes)
  input[:job_class] = attributes['job_class']
  input[:job_arguments] = attributes['arguments']
  plan_self
end
run() click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 32
def run
  input[:job_class].constantize.perform_now(*input[:job_arguments])
end