CrabWatch.CrabWatch Class Reference

Inheritance diagram for CrabWatch.CrabWatch:

Public Member Functions
def	__init__ (self, project, action=getOutput)
def	run (self)
def	setThreshold (self, threshold)

Public Attributes
	action
	finish
	lock
	project
	threshold

Detailed Description

Definition at line 6 of file CrabWatch.py.

Constructor & Destructor Documentation

def CrabWatch.CrabWatch.__init__	(		self,
			project,
			action = getOutput
	)

Definition at line 10 of file CrabWatch.py.

    def __init__(self, project, action = getOutput):
        Thread.__init__(self)
        self.project = project
        self.action = action
        self.threshold = 100.0

        self.lock = Lock()
        self.finish = Event() 
 

Member Function Documentation

def CrabWatch.CrabWatch.run

(

self

)

Definition at line 22 of file CrabWatch.py.

References CrabWatch.CrabWatch.action, crabWrap.convertStatus(), crabWrap.crabStatus(), CrabWatch.CrabWatch.project, CrabTask.CrabTask.project, and CrabWatch.CrabWatch.threshold.

Referenced by Types.EventID.cppID(), Types.LuminosityBlockID.cppID(), and o2olib.O2OTool.execute().

    def run(self):
        exit = False
        failed=0
        while not exit:
            #if checkStatus(self.project,80.0): break
            try:
               status = crabStatus(self.project)
            except CrabException:
               failed+=1
               print "Crab retrieve status failed (",failed,")"
               if failed>10:
                  raise 
            else:
               statusNew = convertStatus(status)
               print "Relative percentage finished: %.0f%%" % statusNew['Finished']
               print "Relative percentage failed  : %.0f%%" % statusNew['Failed']
               print "Relative percentage running : %.0f%%" % statusNew['Running']
               if statusNew['Failed'] > 50.0: raise RuntimeError('Too many jobs have failed (%.0f%%).' % statusNew['Failed'])
               if statusNew['Finished'] >= self.threshold: break
   
               self.lock.acquire()
               if self.finish.isSet(): exit = True 
               self.lock.release()
 
            if not exit: time.sleep(180)
 
        print "Finished..."

        if self.action: self.action(self.project)

def CrabWatch.CrabWatch.setThreshold	(		self,
			threshold
	)

Definition at line 19 of file CrabWatch.py.

References objects.autophobj.float, and CrabWatch.CrabWatch.threshold.

    def setThreshold(self,threshold):
        self.threshold = float(threshold)

Member Data Documentation

CrabWatch.CrabWatch.action

Definition at line 13 of file CrabWatch.py.

Referenced by CrabWatch.CrabWatch.run().

CrabWatch.CrabWatch.finish

Definition at line 17 of file CrabWatch.py.

Referenced by progressbar.ProgressBar.__next__().

CrabWatch.CrabWatch.lock

Definition at line 16 of file CrabWatch.py.

CrabWatch.CrabWatch.project

Definition at line 12 of file CrabWatch.py.

Referenced by CrabWatch.CrabWatch.run().

CrabWatch.CrabWatch.threshold

Definition at line 14 of file CrabWatch.py.

Referenced by utils.StatisticalTest.get_status(), CrabWatch.CrabWatch.run(), and CrabWatch.CrabWatch.setThreshold().