class Xanthus::Job

Attributes

inputs[RW]
iterations[RW]
name[RW]
outputs[RW]
post_instructions[RW]
pre_instructions[RW]
tasks[RW]

Public Class Methods

new() click to toggle source
# File lib/xanthus/job.rb, line 14
def initialize
  @iterations = 0
  @tasks = Hash.new
  @outputs = Hash.new
  @inputs = Hash.new
  @pre_instructions = nil
  @post_instructions = nil
end

Public Instance Methods

destroy(machine) click to toggle source
# File lib/xanthus/job.rb, line 99
def destroy machine
  Dir.chdir machine.to_s do
    system('vagrant', 'destroy', '-f')
    system('rm', '-rf', '.vagrant')
  end
end
execute(config, iteration) click to toggle source
# File lib/xanthus/job.rb, line 106
def execute config, iteration
  puts "Running job #{name.to_s}-#{iteration.to_s}..."
  FileUtils.mkdir_p 'tmp'
  Dir.chdir 'tmp' do
    self.host_scripts config
    @tasks.each do |machine, templates|
      self.setup_env machine, templates, config
    end
    self.execute_pre_instructions unless @pre_instructions.nil?
    @tasks.each do |machine, templates|
      self.run machine
    end
    self.execute_post_instructions unless @post_instructions.nil?
    @tasks.each do |machine, templates|
      self.halt machine
    end
    @tasks.each do |machine, templates|
      self.destroy machine
    end
  end
  system('mv', 'tmp', "#{name.to_s}-#{iteration.to_s}")
  system('tar', '-czvf', "#{name.to_s}-#{iteration.to_s}.tar.gz", "#{name.to_s}-#{iteration.to_s}")
  system('rm', '-rf', "#{name.to_s}-#{iteration.to_s}")
  config.github_conf.add("#{name.to_s}-#{iteration.to_s}.tar.gz") unless config.github_conf.nil?
  config.github_conf.push unless config.github_conf.nil?
  config.dataverse_conf.add("#{name.to_s}-#{iteration.to_s}.tar.gz") unless config.dataverse_conf.nil?
  puts "Job #{name.to_s}-#{iteration.to_s} done."
end
execute_post_instructions() click to toggle source
# File lib/xanthus/job.rb, line 88
def execute_post_instructions
  puts 'Running post instructions...'
  system('sh', './post.sh')
end
execute_pre_instructions() click to toggle source
# File lib/xanthus/job.rb, line 77
def execute_pre_instructions
  puts 'Running pre instructions...'
  system('sh', './pre.sh')
end
halt(machine) click to toggle source
# File lib/xanthus/job.rb, line 93
def halt machine
  Dir.chdir machine.to_s do
    system('vagrant', 'halt')
  end
end
host_scripts(config) click to toggle source
# File lib/xanthus/job.rb, line 60
def host_scripts config
  puts 'Setting up host scripts...'
  if !@pre_instructions.nil?
    script = Script.new(@pre_instructions, config).to_s
    File.open('pre.sh', 'w+') do |f|
      f.write(script)
    end
  end

  if !@post_instructions.nil?
    script = Script.new(@post_instructions, config).to_s
    File.open('post.sh', 'w+') do |f|
      f.write(script)
    end
  end
end
output_script(machine, outputs) click to toggle source
# File lib/xanthus/job.rb, line 23
def output_script machine, outputs
  script = "vagrant plugin install vagrant-scp\n"
  outputs.each do |name, path|
    script += "vagrant scp :#{path} output/#{name}.data\n"
  end
  return script
end
run(machine) click to toggle source
# File lib/xanthus/job.rb, line 82
def run machine
  Dir.chdir machine.to_s do
    system('vagrant', 'up')
  end
end
setup_env(machine, scripts, config) click to toggle source
# File lib/xanthus/job.rb, line 31
def setup_env machine, scripts, config
  puts 'Setting up task on machine '+machine.to_s+'...'
  FileUtils.mkdir_p machine.to_s
  Dir.chdir machine.to_s do
    if !@inputs[machine].nil?
      @inputs[machine].each do |name|
        system('cp', '-f', "../../#{name}", "#{name}")
      end
    end
    FileUtils.mkdir_p 'output'
    puts 'Creating provision files...'
    File.open('Vagrantfile', 'w+') do |f|
      f.write(config.vms[machine].to_vagrant)
    end
    script = Script.new(scripts, config).to_s
    File.open('provision.sh', 'w+') do |f|
      f.write(script)
    end
    script = 'echo "nothing to do"'
    script = self.output_script(machine, @outputs[machine]) unless  @outputs[machine].nil?
    # add simple support for Windows
    before_halt_hook = "before_halt.#{sys_script_ext}"
    File.open(before_halt_hook, 'w+') do |f|
      f.write(script)
    end
    system('chmod', '+x', before_halt_hook)
  end
end