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.4 by spiga, Wed Mar 5 18:30:40 2008 UTC vs.
Revision 1.6 by slacapra, Fri Mar 7 17:25:23 2008 UTC

# Line 46 | Line 46 | class DBinterface:
46          self.task = common.bossSession.loadTaskByID(1)
47          return self.task
48  
49 +    def getJob(self, n):
50 +
51 +        self.job = common.bossSession.loadJobByID(1,n)
52 +        return self.job
53  
54  
55      def createTask_(self, optsToSave):      
56          """
57          Task declaration
58          with the first coniguration stuff
59 <         {'server_name': 'crabas.lnl.infn.it/data1/cms/', '-scheduler': 'glite', '-jobtype': 'cmssw', '-server_mode': '0'}
59 >        {'server_name': 'crabas.lnl.infn.it/data1/cms/', '-scheduler': 'glite', '-jobtype': 'cmssw', '-server_mode': '0'}
60  
61          """
62          opt={}
63 <        if optsToSave['server_mode'] == 1: opt['serverName']=optsToSave['server_name']
63 >        opt['serverName']=optsToSave.get('server_name',0)
64          opt['jobType']=optsToSave['jobtype']  
65          opt[ 'name']=common.work_space.taskName()  
66          task = Task( opt )
# Line 86 | Line 90 | class DBinterface:
90          jobs = []
91          for id in range(nj):
92              parameters = {}
93 <            parameters['name'] = 'job' + str(id)
93 >            parameters['name'] = id
94              job = Job(parameters)
95              jobs.append(job)    
96          task.addJobs(jobs)
# Line 111 | Line 115 | class DBinterface:
115          """
116          task = common.bossSession.loadTaskByID(1)
117          #task = common.bossSession.loadTaskByName( common.work_space.taskName())
118 <        common.bossSession.getRunningInstance(task.jobs[nj])
118 >        common.bossSession.getRunningInstance(task.jobs[nj-1])
119          for key in optsToSave.keys():
120 <            task.jobs[nj].runningJob[key] = optsToSave[key]
120 >            task.jobs[nj-1].runningJob[key] = optsToSave[key]
121          common.bossSession.updateDB( task )
122          return
123  
# Line 198 | Line 202 | class DBinterface:
202          task = common.bossSession.loadTaskByID(1)
203         # task = common.bossSession.loadTaskByName( common.work_space.taskName() )
204          for i in jobs:
205 <            common.bossSession.getRunningInstance(task.jobs[i])
206 <            lines.append(task.jobs[i].runningJob[attr])
205 >            common.bossSession.getRunningInstance(task.jobs[i-1])
206 >            lines.append(task.jobs[i-1].runningJob[attr])
207          return lines
208  
209      def queryDistJob(self, attr):
# Line 207 | Line 211 | class DBinterface:
211          Returns the list of distinct value for a given job attributes
212          '''
213          distAttr=[]
214 <        task = common.bossSession.loadJobDistAttr( 1, attr )
214 >        task = common.bossSession.loadJobDist( 1, attr )
215          for i in task: distAttr.append(i[attr])  
216          return  distAttr
217  
218 <    def queryDistJobHadr(self, attr_1, attr_2, list):
218 >    def queryDistJob_Attr(self, attr_1, attr_2, list):
219          '''
220          Returns the list of distinct value for a given job attributes
221          '''
222          distAttr=[]
223 <        task = common.bossSession.loadJobDistAttrHadr( 1, attr_1, attr_2, list )
223 >        task = common.bossSession.loadJobDistAttr( 1, attr_1, attr_2, list )
224          for i in task: distAttr.append(i[attr_1])  
225          return  distAttr
226 +
227      def queryAttrJob(self, attr, field):
228          '''
229          Returns the list of jobs matching the given attribute

Diff Legend

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