module Dynflow::ActiveJob::QueueAdapters::QueueMethods
Public Instance Methods
enqueue(job)
click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 5 def enqueue(job) ::Rails.application.dynflow.world.trigger do |world| job.provider_job_id = job.job_id world.plan_with_options(id: job.provider_job_id, action_class: JobWrapper, args: [job.serialize]) end end
enqueue_at(job, timestamp)
click to toggle source
# File lib/dynflow/active_job/queue_adapter.rb, line 12 def enqueue_at(job, timestamp) job.provider_job_id = job.job_id ::Rails.application.dynflow.world .delay_with_options(id: job.provider_job_id, action_class: JobWrapper, delay_options: { :start_at => Time.at(timestamp) }, args: [job.serialize]) end