class Dynflow::ActiveJob::QueueAdapters::JobWrapper

Public Instance Methods

label() click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 49
def label
  input[:job_class]
end
plan(attributes) click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 38
def plan(attributes)
  input[:job_class] = attributes['job_class']
  input[:queue] = attributes['queue_name']
  input[:job_data] = attributes
  plan_self
end
queue() click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 34
def queue
  input[:queue].to_sym
end
rescue_strategy() click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 53
def rescue_strategy
  Action::Rescue::Skip
end
run() click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 45
def run
  ::ActiveJob::Base.execute(input[:job_data])
end