Class: WorkflowManager::Cluster

Inherits:
Object
  • Object
show all
Defined in:
lib/workflow_manager/cluster.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name = '', log_dir = '') ⇒ Cluster

Returns a new instance of Cluster.



9
10
11
12
13
 
# File 'lib/workflow_manager/cluster.rb', line 9

def initialize(name='', log_dir='')
  @name = name
  @options = {}
  @log_dir = log_dir
end

Instance Attribute Details

#log_dir ⇒ Object

Returns the value of attribute log_dir.



8
9
10
 
# File 'lib/workflow_manager/cluster.rb', line 8

def log_dir
  @log_dir
end

#name ⇒ Object

Returns the value of attribute name.



6
7
8
 
# File 'lib/workflow_manager/cluster.rb', line 6

def name
  @name
end

#options ⇒ Object (readonly)

Returns the value of attribute options.



7
8
9
 
# File 'lib/workflow_manager/cluster.rb', line 7

def options
  @options
end

Instance Method Details

#cluster_nodes ⇒ Object 



37
38
 
# File 'lib/workflow_manager/cluster.rb', line 37

def cluster_nodes
end

#copy_commands(org_dir, dest_parent_dir, now = nil, queue = "light") ⇒ Object 



31
32
 
# File 'lib/workflow_manager/cluster.rb', line 31

def copy_commands(org_dir, dest_parent_dir, now=nil, queue="light")
end

#default_node ⇒ Object 



39
40
 
# File 'lib/workflow_manager/cluster.rb', line 39

def default_node
end

#delete_command(target) ⇒ Object 



35
36
 
# File 'lib/workflow_manager/cluster.rb', line 35

def delete_command(target)
end

#generate_new_job_script(script_name, script_content) ⇒ Object 



14
15
16
17
18
19
20
21
22
 
# 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) ⇒ Boolean

Returns:

  • (Boolean) 


27
28
 
# File 'lib/workflow_manager/cluster.rb', line 27

def job_ends?(log_file)
end

#job_pending?(job_id) ⇒ Boolean

Returns:

  • (Boolean) 


29
30
 
# File 'lib/workflow_manager/cluster.rb', line 29

def job_pending?(job_id)
end

#job_running?(job_id) ⇒ Boolean

Returns:

  • (Boolean) 


25
26
 
# File 'lib/workflow_manager/cluster.rb', line 25

def job_running?(job_id)
end

#kill_command(job_id) ⇒ Object 



33
34
 
# File 'lib/workflow_manager/cluster.rb', line 33

def kill_command(job_id)
end

#node_list ⇒ Object 



41
42
 
# File 'lib/workflow_manager/cluster.rb', line 41

def node_list
end

#submit_job(script_file, script_content, option = '') ⇒ Object 



23
24
 
# File 'lib/workflow_manager/cluster.rb', line 23

def submit_job(script_file, script_content, option='')
end