class TORQUE::Qstat::Job

Public Class Methods

fields() click to toggle source
# File lib/torque_rm/qstat.rb, line 131
def self.fields
  FIELDS + %w( is_runnig? is_queued? is_exited? is_completed? time memory node )
end
json_load(json) click to toggle source
# File lib/torque_rm/qstat.rb, line 147
def self.json_load(json)
  JSON.load(json)
end
new(*args) click to toggle source

add here your custom method for Qstat::Job

Calls superclass method TORQUE::Qstat::EnanchedOpenStruct::new
# File lib/torque_rm/qstat.rb, line 73
def initialize(*args)
  super(*args)
  class_eval do
    alias_method :id, :job_id
  end
end

Public Instance Methods

completed?()
Alias for: is_completed?
del()
Alias for: rm
delete()
Alias for: rm
exited?()
Alias for: is_exited?
fields() click to toggle source
# File lib/torque_rm/qstat.rb, line 127
def fields
  FIELDS + %w( is_runnig? is_queued? is_exited? is_completed? time memory node )
end
is_completed?() click to toggle source
# File lib/torque_rm/qstat.rb, line 85
def is_completed?
  job_state == 'C'
end
Also aliased as: completed?
is_exited?() click to toggle source
# File lib/torque_rm/qstat.rb, line 90
def is_exited?
  job_state == 'E'
end
Also aliased as: exited?
is_in_queue?()
Alias for: is_queued?
is_queued?() click to toggle source
# File lib/torque_rm/qstat.rb, line 95
def is_queued?
  job_state == 'Q'
end
Also aliased as: queued?, is_in_queue?
is_runnig?() click to toggle source
# File lib/torque_rm/qstat.rb, line 80
def is_runnig?
  job_state == 'R'
end
Also aliased as: running?
memory() click to toggle source
# File lib/torque_rm/qstat.rb, line 105
def memory
  (resources_used && resources_used.mem) ? (resources_used.mem.split("kb").first.to_f/1000).round(1) : "0"
end
node() click to toggle source
# File lib/torque_rm/qstat.rb, line 109
def node 
  exec_host ? exec_host.split("+").map {|n| n.split(".").first}.uniq.join(",") : "-"
end
procs() click to toggle source
# File lib/torque_rm/qstat.rb, line 113
                def procs
                        if resource_list.ncpus
                                return resource_list.ncpus
                        elsif resource_list.nodes
  if resource_list.nodes.is_a? String
                                  return resource_list.nodes.split("ppn=")[-1]
  else
    return resource_list.nodes
  end
                        else
                return "-"
end
                end
queued?()
Alias for: is_queued?
rm() click to toggle source
# File lib/torque_rm/qstat.rb, line 151
def rm
  Qdel.rm(job_id)
end
Also aliased as: del, delete
running?()
Alias for: is_runnig?
time() click to toggle source
# File lib/torque_rm/qstat.rb, line 101
def time
                          return (resources_used && resources_used.walltime) ? resources_used.walltime[:diff] : "-" #using time_diff it prints a nice report in case of more than 1 day
end
to_json(*a) click to toggle source
# File lib/torque_rm/qstat.rb, line 143
def to_json(*a)
  to_map.to_json(*a)
end
to_map() click to toggle source

alias to_hash to_h

# File lib/torque_rm/qstat.rb, line 137
def to_map
  map = Hash.new
  self.members.each { |m| map[m] = self[m] }
  map
end