Changeset 512 for trunk/jobmond
- Timestamp:
- 03/07/08 17:58:33 (15 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/jobmond/jobmond.py
r508 r512 462 462 """Submit job info list""" 463 463 464 global BATCH_API 465 464 466 self.dp.multicastGmetric( 'MONARCH-HEARTBEAT', str( int( int( self.cur_time ) + int( self.timeoffset ) ) ) ) 465 467 … … 483 485 self.dp.multicastGmetric( 'MONARCH-RJ', str( running_jobs ), 'uint32', 'jobs' ) 484 486 self.dp.multicastGmetric( 'MONARCH-QJ', str( queued_jobs ), 'uint32', 'jobs' ) 487 488 # Report down/offline nodes in batch (PBS only ATM) 489 # 490 if BATCH_API == 'pbs': 491 492 downed_nodes = list() 493 offline_nodes = list() 494 495 l = ['state'] 496 497 for name, node in self.pq.getnodes().items(): 498 499 if ( node[ 'state' ].find( "down" ) != -1 ): 500 501 downed_nodes.append( name ) 502 503 if ( node[ 'state' ].find( "offline" ) != -1 ): 504 505 offline_nodes.append( name ) 506 507 self.dp.multicastGmetric( 'MONARCH-DOWN' , str( downed_nodes ), 'uint32', 'jobs' ) 508 self.dp.multicastGmetric( 'MONARCH-OFFLINE', str( offline_nodes ), 'uint32', 'jobs' ) 485 509 486 510 # Now let's spread the knowledge
Note: See TracChangeset
for help on using the changeset viewer.