Changeset 98


Ignore:
Timestamp:
04/20/05 10:50:33 (19 years ago)
Author:
bastiaans
Message:

daemon/togad.py:

  • Misc bugfix.
  • Now entrys to 'job_nodes' table are created again
File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/daemon/togad.py

    r97 r98  
    214214                        elif valname == 'nodes' and value:
    215215
    216                                 self.addNodes( value )
     216                                ids = self.addNodes( value )
    217217                                node_list = value
    218218
     
    220220
    221221                        self.setDatabase( "INSERT INTO jobs ( %s ) VALUES ( %s )" %( insert_col_str, insert_val_str ) )
    222                         #ids = self.getNodeIds( node_list )
    223 
    224                         #self.addJobNodes( job_id, ids )
     222                        self.addJobNodes( job_id, ids )
     223
    225224                elif action == 'update':
    226225
     
    228227
    229228        def addNodes( self, hostnames ):
     229
     230                ids = [ ]
    230231
    231232                for node in hostnames:
     
    235236                        if not id:
    236237                                self.setDatabase( "INSERT INTO nodes ( node_hostname ) VALUES ( '%s' )" %node )
     238                                id = self.getNodeId( node )
     239
     240                        ids.append( id )
     241
     242                return ids
    237243
    238244        def addJobNodes( self, jobid, nodes ):
     
    393399
    394400        jobAttrs = { }
    395         jobs_to_store = [ ]
    396401
    397402        def __init__( self ):
    398403
    399404                self.ds = DataSQLStore( TOGA_SQL_DBASE.split( '/' )[0], TOGA_SQL_DBASE.split( '/' )[1] )
     405                self.jobs_processed = [ ]
     406                self.jobs_to_store = [ ]
    400407
    401408        def startElement( self, name, attrs ):
     
    409416               
    410417                jobinfo = { }
    411                 self.jobs_processed = [ ]
    412418
    413419                if name == 'METRIC':
Note: See TracChangeset for help on using the changeset viewer.