Changeset 356
- Timestamp:
- 04/11/18 13:57:42 (6 years ago)
- Location:
- trunk/examples
- Files:
-
- 13 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/examples/JobParser.py
r323 r356 251 251 jp.read(sys.argv[1]) 252 252 except IndexError: 253 print( "Usage: %s <jobscript>" %(sys.argv[0]))253 print(("Usage: %s <jobscript>" %(sys.argv[0]))) 254 254 sys.exit(1) 255 255 … … 261 261 e, e_txt = pbs.error() 262 262 if e: 263 print( e, e_txt)263 print((e, e_txt)) 264 264 else: 265 265 print(job_id) -
trunk/examples/ha_server.py
r225 r356 17 17 pbs_server = pbs.pbs_default() 18 18 if not pbs_server: 19 print "No default pbs server"19 print("No default pbs server") 20 20 sys.exit(1) 21 21 22 22 con = pbs.pbs_connect(pbs_server) 23 23 if con == -1: 24 print "Default pbs server connection failed"24 print("Default pbs server connection failed") 25 25 pbs_server = pbs.pbs_fbserver() 26 26 if not pbs_server: 27 print "No pbs fallback server"27 print("No pbs fallback server") 28 28 sys.exit(1) 29 29 else: 30 30 con = pbs.pbs_connect(pbs_server) 31 31 if con == -1: 32 print "pbs fallback server connection failed"32 print("pbs fallback server connection failed") 33 33 sys.exit(1) 34 34 35 print "Connected to %s" %(pbs_server)35 print("Connected to %s" %(pbs_server)) 36 36 37 37 def method2(): … … 39 39 server_list = pbs.pbs_get_server_list().split(',') 40 40 except AttributeError, detail: 41 print 'The installed torque version does not support pbs_get_server_list function'41 print('The installed torque version does not support pbs_get_server_list function') 42 42 sys.exit(1) 43 43 for server in server_list: … … 48 48 49 49 if con == -1: 50 print 'Could not connect to a server (%s)' %('.'.join(server_list))50 print('Could not connect to a server (%s)' %('.'.join(server_list))) 51 51 sys.exit(1) 52 52 53 print "Connected to %s" %(pbs_server)53 print("Connected to %s" %(pbs_server)) 54 54 55 55 -
trunk/examples/logpbs.py
r110 r356 15 15 # 16 16 if pbs.log_open('', '.'): 17 print 'Could not open log file'17 print('Could not open log file') 18 18 sys.exit(1) 19 19 … … 27 27 # 28 28 if pbs.log_open('', '/var/spool/torque/sched_logs'): 29 print 'Could not open log file in /var/spool/torque/sched_logs'29 print('Could not open log file in /var/spool/torque/sched_logs') 30 30 sys.exit(1) 31 31 -
trunk/examples/new_interface.py
r339 r356 34 34 node = p.getnode("r2n2", l) 35 35 36 print node.name37 print node.name, node['np']36 print(node.name) 37 print(node.name, node['np']) 38 38 39 39 sys.exit(0) … … 41 41 #nodes = p.getnodes(l) 42 42 for id in nodes: 43 print id43 print(id) 44 44 45 45 try: 46 print nodes[id].np47 print nodes[id].status.arch48 print nodes[id].status.uname49 print nodes[id].state46 print(nodes[id].np) 47 print(nodes[id].status.arch) 48 print(nodes[id].status.uname) 49 print(nodes[id].state) 50 50 except PBSError, detail: 51 print detail51 print(detail) 52 52 pass 53 53 -
trunk/examples/node_event_parse.py
r287 r356 19 19 p = PBSQuery() 20 20 node = p.getnode('gb-r7n3') 21 print node['event']21 print(node['event']) -
trunk/examples/pbs_joblogin
r302 r356 42 42 def usage(a): 43 43 if a == 'pbs_jobmonitor': 44 print a,'shows the system usage of a node where a job is running'44 print(a,'shows the system usage of a node where a job is running') 45 45 if a == 'pbs_joblogin': 46 print a,'logs you in to a node where a job is running'46 print(a,'logs you in to a node where a job is running') 47 47 48 print 'Usage:'49 print a,'<jobnumber> [nodenumber]'50 print 'where <jobnumber> is the number of the job'51 print ' nodenumber is the rank number of the node allocated to the job'52 print ' (default 0)'48 print('Usage:') 49 print(a,'<jobnumber> [nodenumber]') 50 print('where <jobnumber> is the number of the job') 51 print(' nodenumber is the rank number of the node allocated to the job') 52 print(' (default 0)') 53 53 54 54 me = sys.argv[0].split('/')[-1] 55 print '['+me+']'55 print('['+me+']') 56 56 p = PBSQuery() 57 57 … … 76 76 h = job['exec_host'][0] 77 77 except: 78 print 'No such job:',j78 print('No such job:',j) 79 79 sys.exit(1) 80 80 … … 85 85 86 86 nodes = uniq(nodes) 87 print 'Job',j,'is running on',len(nodes),'nodes:'87 print('Job',j,'is running on',len(nodes),'nodes:') 88 88 i=0 89 89 for h in nodes: 90 print h,90 print(h, end=' ') 91 91 i = i+1 92 92 if i > 7: 93 93 i=0 94 print 94 print() 95 95 if i != 0: 96 print 96 print() 97 97 98 98 if num >= len(nodes): 99 print 'No node number',num99 print('No node number',num) 100 100 sys.exit(1) 101 101 102 102 if me == 'pbs_jobmonitor': 103 103 user=job['Job_Owner'][0].split('@')[0] 104 print 'top for node #',num,':',nodes[num],'user:',user104 print('top for node #',num,':',nodes[num],'user:',user) 105 105 sys.stdout.flush() 106 106 os.system('ssh '+nodes[num]+' top -n1 -b -u ' + user) … … 108 108 if me == 'pbs_joblogin': 109 109 user = os.getenv('USER') 110 print 'logging in to node #',num,':',nodes[num],'user:',user110 print('logging in to node #',num,':',nodes[num],'user:',user) 111 111 sys.stdout.flush() 112 112 os.system('ssh -X '+nodes[num]) -
trunk/examples/pbs_jobmonitor
r355 r356 42 42 def usage(a): 43 43 if a == 'pbs_jobmonitor': 44 print a,'shows the system usage of a node where a job is running'44 print(a,'shows the system usage of a node where a job is running') 45 45 if a == 'pbs_joblogin': 46 print a,'logs you in to a node where a job is running'46 print(a,'logs you in to a node where a job is running') 47 47 48 print 'Usage:'49 print a,'<jobnumber> [nodenumber]'50 print 'where <jobnumber> is the number of the job'51 print ' nodenumber is the rank number of the node allocated to the job'52 print ' (default 0)'48 print('Usage:') 49 print(a,'<jobnumber> [nodenumber]') 50 print('where <jobnumber> is the number of the job') 51 print(' nodenumber is the rank number of the node allocated to the job') 52 print(' (default 0)') 53 53 54 54 me = sys.argv[0].split('/')[-1] 55 print '['+me+']'55 print('['+me+']') 56 56 p = PBSQuery() 57 57 … … 76 76 h = job['exec_host'][0] 77 77 except: 78 print 'No such job:',j78 print('No such job:',j) 79 79 sys.exit(1) 80 80 … … 85 85 86 86 nodes = uniq(nodes) 87 print 'Job',j,'is running on',len(nodes),'nodes:'87 print('Job',j,'is running on',len(nodes),'nodes:') 88 88 i=0 89 89 for h in nodes: 90 print h,90 print(h, end=' ') 91 91 i = i+1 92 92 93 93 if i != 0: 94 print 94 print() 95 95 96 96 if num >= len(nodes): 97 print 'No node number',num97 print('No node number',num) 98 98 sys.exit(1) 99 99 100 100 if me == 'pbs_jobmonitor': 101 101 user=job['Job_Owner'][0].split('@')[0] 102 print 'top for node #',num,':',nodes[num],'user:',user102 print('top for node #',num,':',nodes[num],'user:',user) 103 103 sys.stdout.flush() 104 104 os.system('ssh '+nodes[num]+' top -n1 -b -u ' + user) … … 106 106 if me == 'pbs_joblogin': 107 107 user = os.getenv('USER') 108 print 'logging in to node #',num,':',nodes[num],'user:',user108 print('logging in to node #',num,':',nodes[num],'user:',user) 109 109 sys.stdout.flush() 110 110 os.system('ssh -X '+nodes[num]) -
trunk/examples/pbs_version.py
r286 r356 15 15 pbs_server = pbs.pbs_default() 16 16 if not pbs_server: 17 print 'No default server'17 print('No default server') 18 18 sys.exit(1) 19 19 … … 25 25 server_info = pbs.pbs_statserver(con, attr_l, 'NULL') 26 26 for entry in server_info: 27 print entry.name27 print(entry.name) 28 28 for attrib in entry.attribs: 29 print '\t', attrib.name, ' = ', attrib.value29 print('\t', attrib.name, ' = ', attrib.value) 30 30 31 31 main() -
trunk/examples/pbsmon.py
r242 r356 63 63 while start < items: 64 64 65 print ' ',65 print(' ', end=' ') 66 66 for j in range(start,end): 67 print format %(nl[j]) ,67 print(format %(nl[j]), end=' ') 68 68 69 print '\n ',69 print('\n ', end=' ') 70 70 for j in range(start,end): 71 print format %(sl[j]) ,71 print(format %(sl[j]), end=' ') 72 72 73 print '\n'73 print('\n') 74 74 75 75 start = end … … 84 84 for key in translate_state.keys(): 85 85 value = translate_state[key] 86 print "%3s %-21s : %d\t |" %( value, key, sl.count(value) ),86 print("%3s %-21s : %d\t |" %( value, key, sl.count(value) ), end=' ') 87 87 if n%2: 88 print ''88 print('') 89 89 n = n + 1 90 90 … … 99 99 pbs_server = pbs.pbs_default() 100 100 if not pbs_server: 101 print "No default pbs server, usage: pbsmon [server] "101 print("No default pbs server, usage: pbsmon [server] ") 102 102 sys.exit(1) 103 103 … … 105 105 if con < 0: 106 106 errno, text = pbs.error() 107 print errno, text107 print(errno, text) 108 108 sys.exit(1) 109 109 -
trunk/examples/pbsnodes-a.py
r70 r356 19 19 pbs_server = pbs.pbs_default() 20 20 if not pbs_server: 21 print "No default pbs server"21 print("No default pbs server") 22 22 sys.exit(1) 23 23 … … 27 27 28 28 for node in nodes: 29 print node.name29 print(node.name) 30 30 for attrib in node.attribs: 31 print '\t', attrib.name, '=', attrib.value31 print('\t', attrib.name, '=', attrib.value) 32 32 33 33 main() -
trunk/examples/rack_pbsmon.py
r134 r356 44 44 45 45 if not pbs_server: 46 print 'No default pbs server, usage: %s [server]' % os.path.basename(sys.argv[0])46 print('No default pbs server, usage: %s [server]' % os.path.basename(sys.argv[0])) 47 47 sys.exit(1) 48 48 … … 50 50 if con < 0: 51 51 errno, text = pbs.error() 52 print errno, text52 print(errno, text) 53 53 sys.exit(1) 54 54 … … 86 86 87 87 # print nodes with gb-r%dn%d naming scheme 88 print ' ',88 print(' ', end=' ') 89 89 for rack in xrange(1, N_RACKS+1): 90 print '%2d' % rack,91 print 90 print('%2d' % rack, end=' ') 91 print() 92 92 93 93 for node_nr in xrange(1, NODES_PER_RACK+1): 94 print '%2d' % node_nr,94 print('%2d' % node_nr, end=' ') 95 95 96 96 for rack in xrange(1, N_RACKS+1): … … 98 98 99 99 if node_dict.has_key(node_name): 100 print ' %s' % node_dict[node_name],100 print(' %s' % node_dict[node_name], end=' ') 101 101 102 102 del node_dict[node_name] 103 103 else: 104 print ' ',104 print(' ', end=' ') 105 105 106 106 if node_nr-1 < len(legend): 107 107 state = legend[node_nr-1] 108 print ' %s %-13s : %d' % (PBS_STATES[state], state, count_states[state])108 print(' %s %-13s : %d' % (PBS_STATES[state], state, count_states[state])) 109 109 else: 110 print 110 print() 111 111 112 print 112 print() 113 113 114 114 # any other nodes? … … 118 118 119 119 for node in arr: 120 print '%s %s' % (node, node_dict[node])120 print('%s %s' % (node, node_dict[node])) 121 121 122 print 122 print() 123 123 124 124 # n = 0 -
trunk/examples/resmom_info.py
r132 r356 19 19 20 20 for node in nodes: 21 print node.name, ' :'21 print(node.name, ' :') 22 22 attrs = node.attribs 23 23 for attr in attrs: 24 print '\t%s = %s' %(attr.name, attr.value)24 print('\t%s = %s' %(attr.name, attr.value)) 25 25 26 26 try: … … 33 33 mom_keys = pbs.get_mom_values(mom_id) 34 34 for key in mom_keys.keys(): 35 print '\t%s = %s' %(key, mom_keys[key])35 print('\t%s = %s' %(key, mom_keys[key])) 36 36 37 print '\nTesting list with user supplied keywords'37 print('\nTesting list with user supplied keywords') 38 38 39 39 l = [ 'bas', 'ncpus', 'loadave' ] 40 40 mom_keys = pbs.get_mom_values(mom_id, l) 41 41 for key in mom_keys.keys(): 42 print '\t%s = %s' %(key, mom_keys[key])43 print ''42 print('\t%s = %s' %(key, mom_keys[key])) 43 print('') 44 44 pbs.closerm(mom_id) 45 45 -
trunk/examples/set_property.py
r235 r356 16 16 pbs_server = pbs.pbs_default() 17 17 if not pbs_server: 18 print 'No default server'18 print('No default server') 19 19 sys.exit(1) 20 20 21 21 if len(sys.argv) < 2: 22 print "Usage: set_property.py <hostname>"22 print("Usage: set_property.py <hostname>") 23 23 sys.exit(1) 24 24 … … 36 36 37 37 if r > 0: 38 print r, ";"38 print(r, ";") 39 39 errno, text = pbs.error() 40 print errno, text40 print(errno, text) 41 41 42 42 main()
Note: See TracChangeset
for help on using the changeset viewer.