class Dynflow::ActiveJob::QueueAdapters::JobWrapper

Public Instance Methods

label() click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 45
def label
  input[:job_class]
end
plan(attributes) click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 34
def plan(attributes)
  input[:job_class] = attributes['job_class']
  input[:job_arguments] = attributes['arguments']
  input[:queue] = attributes['queue_name']
  plan_self
end
queue() click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 30
def queue
  input[:queue].to_sym
end
rescue_strategy() click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 49
def rescue_strategy
  Action::Rescue::Skip
end
run() click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 41
def run
  input[:job_class].constantize.perform_now(*input[:job_arguments])
end