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.63 by mcinquil, Thu Jul 23 08:57:37 2009 UTC vs.
Revision 1.66 by farinafa, Tue Dec 15 13:13:40 2009 UTC

# Line 325 | Line 325 | class DBinterface:
325      def deserXmlStatus(self, reportList):
326  
327          task = self.getTask()
328 +        if int(self.cfg_params.get('WMBS.automation',0)) == 1:
329 +            if len(reportList) ==0:
330 +                msg = 'You are using CRAB with WMBS the server is still creating your jobs.\n'
331 +                msg += '\tPlease wait...'
332 +                raise CrabException(msg)
333 +            newJobs =  len(reportList) - len(task.jobs)
334 +            if newJobs != 0:
335 +                isNew=True  
336 +                if len(task.jobs):isNew=False
337 +                jobL=[]  
338 +                for i in range(1,newJobs+1):
339 +                    jobL.append(len(task.jobs)+i)
340 +                self.createJobs_(jobL,isNew)
341 +
342          for job in task.jobs:
343              if not job.runningJob:
344                  raise CrabException( "Missing running object for job %s"%str(job['jobId']) )
# Line 396 | Line 410 | class DBinterface:
410                  return False
411          return True
412  
413 +    # Method to update arguments w.r.t. resubmission number in order to grant unique output
414 +    def updateResubAttribs(self, jobsL):
415 +        task = self.getTask(jobsL)
416 +        for j in task.jobs:
417 +            common.bossSession.getRunningInstance(j)
418 +            newArgs = "%d %d"%(j.runningJob['jobId'], j.runningJob['submission'])
419 +            j['arguments'] = newArgs
420 +            
421 +        common.bossSession.updateDB(task)
422 +        return
423 +
424  

Diff Legend

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