Changeset 356 for trunk/examples/pbs_jobmonitor
- Timestamp:
- 04/11/18 13:57:42 (6 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
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])
Note: See TracChangeset
for help on using the changeset viewer.