class Dynflow::ActiveJob::QueueAdapters::JobWrapper
Public Instance Methods
label()
click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 41 def label input[:job_class] end
plan(attributes)
click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 30 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 26 def queue input[:queue].to_sym end
run()
click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 37 def run input[:job_class].constantize.perform_now(*input[:job_arguments]) end