class Bosh::Director::JobQueue

Abstracts the delayed jobs system.

Public Instance Methods

enqueue(username, job_class, description, params, deployment = nil) click to toggle source
# File lib/bosh/director/job_queue.rb, line 8
def enqueue(username, job_class, description, params, deployment = nil)
  task = Api::TaskHelper.new.create_task(username, job_class.job_type, description, deployment)

  Delayed::Worker.backend = :sequel
  db_job = Bosh::Director::Jobs::DBJob.new(job_class, task.id, params)
  Delayed::Job.enqueue db_job

  task
end