Changeset 348


Ignore:
Timestamp:
04/27/07 14:07:18 (17 years ago)
Author:
bastiaans
Message:

jobmond/jobmond.py:

  • made getJobData & submitJobData more uniform to work with multiple types of datagatherer
File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/jobmond/jobmond.py

    r347 r348  
    339339                while ( 1 ):
    340340               
    341                         self.jobs = self.getJobData( self.jobs )
    342                         self.submitJobData( self.jobs )
     341                        self.getJobData()
     342                        self.submitJobData()
    343343                        time.sleep( BATCH_POLL_INTERVAL )       
    344344
     
    513513                return 0
    514514
    515         def getJobData( self, known_jobs ):
     515        def getJobData( self ):
    516516                """Gather all data on current jobs in Torque"""
    517 
    518                 if len( known_jobs ) > 0:
    519                         jobs = known_jobs
    520                 else:
    521                         jobs = { }
    522517
    523518                #self.initPbsQuery()
     
    656651                        myAttrs['poll_interval'] = str( BATCH_POLL_INTERVAL )
    657652
    658                         if self.jobDataChanged( jobs, job_id, myAttrs ) and myAttrs['status'] in [ 'R', 'Q' ]:
    659                                 jobs[ job_id ] = myAttrs
     653                        if self.jobDataChanged( self.jobs, job_id, myAttrs ) and myAttrs['status'] in [ 'R', 'Q' ]:
     654                                self.jobs[ job_id ] = myAttrs
    660655
    661656                                #debug_msg( 10, printTime() + ' job %s state changed' %(job_id) )
    662657
    663                 for id, attrs in jobs.items():
     658                for id, attrs in self.jobs.items():
    664659
    665660                        if id not in jobs_processed:
     
    667662                                # This one isn't there anymore; toedeledoki!
    668663                                #
    669                                 del jobs[ id ]
    670 
    671                 return jobs
    672 
    673         def submitJobData( self, jobs ):
     664                                del self.jobs[ id ]
     665
     666        def submitJobData( self ):
    674667                """Submit job info list"""
    675668
     
    678671                # Now let's spread the knowledge
    679672                #
    680                 for jobid, jobattrs in jobs.items():
     673                for jobid, jobattrs in self.jobs.items():
    681674
    682675                        gmetric_val = self.compileGmetricVal( jobid, jobattrs )
Note: See TracChangeset for help on using the changeset viewer.