class WorkflowManager::Cluster
Attributes
log_dir[RW]
name[RW]
options[R]
Public Class Methods
new(name='', log_dir='')
click to toggle source
# File lib/workflow_manager/cluster.rb, line 9 def initialize(name='', log_dir='') @name = name @options = {} @log_dir = log_dir end
Public Instance Methods
cluster_nodes()
click to toggle source
# File lib/workflow_manager/cluster.rb, line 37 def cluster_nodes end
copy_commands(org_dir, dest_parent_dir, now=nil)
click to toggle source
# File lib/workflow_manager/cluster.rb, line 31 def copy_commands(org_dir, dest_parent_dir, now=nil) end
default_node()
click to toggle source
# File lib/workflow_manager/cluster.rb, line 39 def default_node end
delete_command(target)
click to toggle source
# File lib/workflow_manager/cluster.rb, line 35 def delete_command(target) end
generate_new_job_script(script_name, script_content)
click to toggle source
# File lib/workflow_manager/cluster.rb, line 14 def generate_new_job_script(script_name, script_content) new_job_script = File.basename(script_name) + "_" + Time.now.strftime("%Y%m%d%H%M%S%L") new_job_script = File.join(@log_dir, new_job_script) open(new_job_script, 'w') do |out| out.print script_content out.print "\necho __SCRIPT END__\n" end new_job_script end
job_ends?(log_file)
click to toggle source
# File lib/workflow_manager/cluster.rb, line 27 def job_ends?(log_file) end
job_pending?(job_id)
click to toggle source
# File lib/workflow_manager/cluster.rb, line 29 def job_pending?(job_id) end
job_running?(job_id)
click to toggle source
# File lib/workflow_manager/cluster.rb, line 25 def job_running?(job_id) end
kill_command(job_id)
click to toggle source
# File lib/workflow_manager/cluster.rb, line 33 def kill_command(job_id) end
node_list()
click to toggle source
# File lib/workflow_manager/cluster.rb, line 41 def node_list end
submit_job(script_file, script_content, option='')
click to toggle source
# File lib/workflow_manager/cluster.rb, line 23 def submit_job(script_file, script_content, option='') end