python.RunDependentMCTaskIterator.taskIterator Class Reference

Inheritance diagram for python.RunDependentMCTaskIterator.taskIterator:

Collaboration diagram for python.RunDependentMCTaskIterator.taskIterator:

Public Member Functions
def	__init__ (self, task, step)
def	__eq__ (self, another)
def	__iter__ (self)
def	__repr__ (self)
def	__next__ (self)

Public Attributes
	step
	taskit
	offset
	current
	donejob

Detailed Description

iterator over a list of dicts (the 'task'). Each dict must contain 'evts', optionally 'force_new'.

Definition at line 104 of file RunDependentMCTaskIterator.py.

Constructor & Destructor Documentation

__init__()

def python.RunDependentMCTaskIterator.taskIterator.__init__	(		self,
			task,
			step
	)

create the iterator from task (a list of dicts) and step (the max number of evts. per job)
the iterator 

Definition at line 107 of file RunDependentMCTaskIterator.py.

    def __init__(self,task,step):
        """create the iterator from task (a list of dicts) and step (the max number of evts. per job)
        the iterator """
        self.step = step
        self.taskit = itertools.cycle(task)
        self.offset = 0
        self.current = None
        self.donejob = []
        try:
            if min(e['evts'] for e in task) < 0: #py2.4
                raise ValueError("Cannot use empty task lists or negative N(events).")
        except KeyError:
            raise ValueError("Cannot use tasks that don't always define 'evts':", task)
        if (step < 1): raise ValueError("Cannot use step size smaller than 1 in a taskIterator.")
        return
 

Member Function Documentation

__eq__()

def python.RunDependentMCTaskIterator.taskIterator.__eq__	(		self,
			another
	)

Definition at line 123 of file RunDependentMCTaskIterator.py.

    def __eq__(self, another):
        return (self.current == another.current) and (self.step == another.step)
 

__iter__()

def python.RunDependentMCTaskIterator.taskIterator.__iter__

(

self

)

Definition at line 126 of file RunDependentMCTaskIterator.py.

    def __iter__(self):
        return self
 

__next__()

def python.RunDependentMCTaskIterator.taskIterator.__next__

(

self

)

Definition at line 132 of file RunDependentMCTaskIterator.py.

    def __next__(self):
        self.donejob = []
        if (self.current is None):  self.current = next(self.taskit)
        to_do = self.step
        while True:
            if (to_do == 0) : return self.offset, self.current
            can_do = self.current['evts'] - self.offset
            if ( can_do > to_do ) :
                self.donejob.append( self.current.copy() )
                self.donejob[-1].update({'evts':to_do})
                self.offset += to_do
                return self.offset, self.current
            else:
                to_do -= can_do
                self.offset = 0
                pass
            self.donejob.append( self.current.copy() )
            self.donejob[-1].update({'evts':can_do})
            self.current = next(self.taskit)
            if self.current.get('force_new',False): to_do = 0
        raise StopIteration
#
 

__repr__()

def python.RunDependentMCTaskIterator.taskIterator.__repr__

(

self

)

Definition at line 129 of file RunDependentMCTaskIterator.py.

    def __repr__(self):
        return "offset=%i; row=%i,%i" % (self.offset,self.current.get('run',0),self.current.get('lb',0))
 

Member Data Documentation

current

python.RunDependentMCTaskIterator.taskIterator.current

Definition at line 113 of file RunDependentMCTaskIterator.py.

donejob

python.RunDependentMCTaskIterator.taskIterator.donejob

Definition at line 114 of file RunDependentMCTaskIterator.py.

offset

python.RunDependentMCTaskIterator.taskIterator.offset

Definition at line 112 of file RunDependentMCTaskIterator.py.

step

python.RunDependentMCTaskIterator.taskIterator.step

Definition at line 110 of file RunDependentMCTaskIterator.py.

taskit

python.RunDependentMCTaskIterator.taskIterator.taskit

Definition at line 111 of file RunDependentMCTaskIterator.py.

---

The documentation for this class was generated from the following file:

• RunDependentMCTaskIterator.py