Module: Bj::Table::Job::InstanceMethods

Defined in:

lib/bj/table.rb

Instance Method Summary

• #finished ⇒ Object (also: #finished?)
• #run!(options = {}) ⇒ Object
• #title ⇒ Object

Instance Method Details

#finished ⇒ Object Also known as: finished?

# File 'lib/bj/table.rb', line 159

def finished
  reload
  exit_status
end

#run!(options = {}) ⇒ Object

# File 'lib/bj/table.rb', line 165

def run! options = {}
  job = self
  thread = nil
  
  command = job.command
  env = job.env ? YAML.load(job.env) : {}
  stdin = job.stdin || ''
  stdout = job.stdout || ''
  stderr = job.stderr || ''
  started_at = Time.now.utc

  job.state = "starting"
  job.save!

  thread = Util.start command, :cwd=>Bj.rails_root, :env=>env, :stdin=>stdin, :stdout=>stdout, :stderr=>stderr

  job.state = "running"
  job.runner = Bj.hostname
  job.pid = thread.pid
  job.started_at = started_at 

  Bj.transaction(options) do
    job.save!
    job.reload
  end

  exit_status = thread.value

  job.state = "finished"
  job.finished_at = Time.now.utc
  job.stdout = stdout
  job.stderr = stderr
  job.exit_status = exit_status

  Bj.transaction(options) do
    job.save!
    job.reload
  end

  job
end

#title ⇒ Object

# File 'lib/bj/table.rb', line 155

def title
  "job[#{ id }](#{ command })"
end