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