ViewVC Help
View File | Revision Log | Show Annotations | Root Listing
root/cvsroot/COMP/CRAB/python/DBinterface.py
(Generate patch)

Comparing COMP/CRAB/python/DBinterface.py (file contents):
Revision 1.6 by slacapra, Fri Mar 7 17:25:23 2008 UTC vs.
Revision 1.7 by spiga, Mon Mar 17 14:00:59 2008 UTC

# Line 38 | Line 38 | class DBinterface:
38          dbConfig = {'dbName':dbname
39              }
40          common.bossSession = BossLiteAPI( self.db_type, dbConfig)
41 <        
41 >        self.task = common.bossSession.loadTaskByID(1)
42          return
43  
44 <    def getTask(self):
44 >    def getTask(self, jobsList='all'): #, cfg_params):
45  
46 +        #if jobsList == 'all':
47 +        #    self.task = common.bossSession.loadTaskByID(1)
48 +        #else:
49 +        #self.task = common.bossSession.load('1','5')  
50 +        #return self.task[0]
51          self.task = common.bossSession.loadTaskByID(1)
52          return self.task
53  
# Line 60 | Line 65 | class DBinterface:
65  
66          """
67          opt={}
68 <        opt['serverName']=optsToSave.get('server_name',0)
64 <        opt['jobType']=optsToSave['jobtype']  
68 >        if optsToSave['server_mode'] == 1: opt['serverName']=optsToSave['server_name']
69          opt[ 'name']=common.work_space.taskName()  
70          task = Task( opt )
71        
72          common.bossSession.saveTask( task )
69 –        #common.bossSession.updateDB( task )
73          return
74  
75      def updateTask_(self,optsToSave):      
# Line 90 | Line 93 | class DBinterface:
93          jobs = []
94          for id in range(nj):
95              parameters = {}
96 <            parameters['name'] = id
96 >            parameters['name'] = 'job' + str(id)
97              job = Job(parameters)
98              jobs.append(job)    
99          task.addJobs(jobs)
# Line 103 | Line 106 | class DBinterface:
106          """
107          task = common.bossSession.loadTaskByID(1)
108          #task = common.bossSession.loadTaskByName( common.work_space.taskName())
109 <        jobs = common.bossSession.loadJob(task['id'],nj+1)
110 <        for key in optsToSave.keys():
111 <            jobs[key] = optsToSave[key]
112 <            common.bossSession.updateDB( jobs )
109 >        for i in range(len(nj)):
110 >           # jobs = common.bossSession.loadJob(task['id'],i)
111 >            for key in optsToSave[i].keys():
112 >                task.jobs[i][key] = optsToSave[i][key]
113 >        common.bossSession.updateDB( task )
114          return
115  
116      def updateRunJob_(self, nj, optsToSave):      
# Line 115 | Line 119 | class DBinterface:
119          """
120          task = common.bossSession.loadTaskByID(1)
121          #task = common.bossSession.loadTaskByName( common.work_space.taskName())
122 <        common.bossSession.getRunningInstance(task.jobs[nj-1])
123 <        for key in optsToSave.keys():
124 <            task.jobs[nj-1].runningJob[key] = optsToSave[key]
122 >        for i in nj:
123 >            common.bossSession.getRunningInstance(task.jobs[i])
124 >            for key in optsToSave.keys():
125 >                task.jobs[i].runningJob[key] = optsToSave[key]
126          common.bossSession.updateDB( task )
127          return
128  
# Line 234 | Line 239 | class DBinterface:
239              matched.append(i[field])
240          return  matched
241  
242 +
243 +    def queryAttrRunJob(self, attr,field):
244 +        '''
245 +        Returns the list of jobs matching the given attribute
246 +        '''
247 +        matched=[]
248 +        task = common.bossSession.loadJobsByRunningAttr(attr)
249 +        for i in task:
250 +            matched.append(i[field])
251 +        return matched

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines