Sha256: 51b1a32cf60d478058c3cda6cdea3a6cb91dc4dae25bf74f4a63e3dd2b6e6fb9
Contents?: true
Size: 1.04 KB
Versions: 11
Compression:
Stored size: 1.04 KB
Contents
class CodeRunner
# A module containing methods for submitting runs using the CodeRunner
# launcher. Typically this would be used on a home Linux system or in
# an interactive session on a supercomputer.
module Launcher
def launcher_prefix
ENV['CODE_RUNNER_LAUNCHER']
end
def use_launcher
launcher_prefix and launcher_prefix.size > 0
end
def queue_status_launcher
%x[cat #{CodeRunner.launcher_directory}/queue_status.txt | grep sh] +
%x[cat #{CodeRunner.launcher_directory}/queue_status2.txt | grep sh]
end
def execute_launcher
launch_id = "#{Time.now.to_i}#{$$}"
fname = "#{CodeRunner.launcher_directory}/#{launch_id}"
File.open(fname + '.start', 'w'){|file| file.print "cd #{Dir.pwd};", run_command, "\n"}
sleep 2 until FileTest.exist? fname + '.pid'
pid = File.read(fname + '.pid').to_i
FileUtils.rm fname + '.pid'
return pid
end
def cancel_job_launcher
fname = CodeRunner.launcher_directory + "/#{$$}.stop"
File.open(fname, 'w'){|file| file.puts "\n"}
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems