Module: Dynflow::ActiveJob::QueueAdapters::QueueMethods

Included in:
DynflowAdapter, DynflowAdapter
Defined in:
lib/dynflow/active_job/queue_adapter.rb

Instance Method Summary collapse

Instance Method Details

#enqueue(job) ⇒ Object 



7
8
9
10
11
12
 
# File 'lib/dynflow/active_job/queue_adapter.rb', line 7

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) ⇒ Object 



14
15
16
17
18
19
20
21
 
# File 'lib/dynflow/active_job/queue_adapter.rb', line 14

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