# File lib/dynflow/active_job/queue_adapter.rb, line 5 def enqueue(job) ::Rails.application.dynflow.world.trigger(JobWrapper, job.serialize).tap do |plan| job.provider_job_id = plan.id end end
# File lib/dynflow/active_job/queue_adapter.rb, line 11 def enqueue_at(job, timestamp) ::Rails.application.dynflow.world.delay(JobWrapper, { :start_at => Time.at(timestamp) }, job.serialize).tap do |plan| job.provider_job_id = plan.id end end