class Dynflow::ActiveJob::QueueAdapters::JobWrapper
Public Instance Methods
label()
click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 50 def label input[:job_class] end
plan(attributes)
click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 39 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 35 def queue input[:queue].to_sym end
rescue_strategy()
click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 54 def rescue_strategy Action::Rescue::Skip end
run()
click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 46 def run ::ActiveJob::Base.execute(input[:job_data]) end