Skip to content
Snippets Groups Projects

add optional host parameter in parse_qstat_n1

Merged Mads M. Pedersen requested to merge pbswrap_mmpe_fix into master
1 file
+ 10
16
Compare changes
  • Side-by-side
  • Inline
@@ -176,7 +176,7 @@ def parse_pbsnode_lall(output):
@@ -176,7 +176,7 @@ def parse_pbsnode_lall(output):
return pbsnodes, nodes
return pbsnodes, nodes
def parse_qstat_n1(output):
def parse_qstat_n1(output, hostname=None):
"""
"""
Parse the output of qstat -n1
Parse the output of qstat -n1
"""
"""
@@ -188,26 +188,22 @@ def parse_qstat_n1(output):
@@ -188,26 +188,22 @@ def parse_qstat_n1(output):
host = {}
host = {}
users = {}
users = {}
# get the hostname
# get the hostname
hostname = socket.gethostname()
if hostname is None:
if hostname[:5] == 'g-000':
hostname = socket.gethostname()
host['name'] = 'gorm'
if 'jess' in hostname:
host['cpu_per_node'] = 12
else:
# 272 nodes are 2 x 10 core (twenty) processors
host['name'] = 'jess'
host['name'] = 'jess'
#total_nodes = 80
host['cpu_per_node'] = 20
host['cpu_per_node'] = 20
 
else:
 
host['name'] = 'gorm'
 
host['cpu_per_node'] = 12
 
# take the available nodes in nr_nodes: it excludes the ones
# take the available nodes in nr_nodes: it excludes the ones
# who are down
# who are down
#queue['_total_cpu_'] = cpu_node*nr_nodes
#queue['_total_cpu_'] = cpu_node*nr_nodes
ii = 0
for line in output[5:]:
for line in output:
if len(line.strip()) == 0:
# first 5 are not relevant
if ii < 5:
ii += 1
continue
continue
items = line.split()
items = line.split()
queue = items[2]
queue = items[2]
@@ -268,8 +264,6 @@ def parse_qstat_n1(output):
@@ -268,8 +264,6 @@ def parse_qstat_n1(output):
except KeyError:
except KeyError:
nodesload[node] = [userid]
nodesload[node] = [userid]
ii += 1
return users, host, nodesload
return users, host, nodesload
# FIXME: counts diffferent compared to launch.py....
# FIXME: counts diffferent compared to launch.py....
Loading