class Dwf::Worker

Public Instance Methods

perform(workflow_id, job_name) click to toggle source
# File lib/dwf/worker.rb, line 10
def perform(workflow_id, job_name)
  job = client.find_job(workflow_id, job_name)
  return job.enqueue_outgoing_jobs if job.succeeded?

  job.mark_as_started
  job.perform
  job.mark_as_finished
  job.enqueue_outgoing_jobs if job.cb_build_in?
end

Private Instance Methods

client() click to toggle source
# File lib/dwf/worker.rb, line 22
def client
  @client ||= Dwf::Client.new
end