|
def | __init__ (self, name='Echo', trf=None) |
|
def | execute (self) |
|
def | inData (self) |
|
def | inData (self, value) |
|
def | outData (self) |
|
def | outData (self, value) |
|
def | myMerger (self) |
| Now define properties for these data members. More...
|
|
def | name (self) |
|
def | name (self, value) |
|
def | substep (self) |
|
def | trf (self) |
|
def | trf (self, value) |
|
def | inDataUpdate (self, value) |
|
def | outDataUpdate (self, value) |
|
def | input (self) |
|
def | output (self) |
|
def | extraMetadata (self) |
|
def | hasExecuted (self) |
|
def | rc (self) |
|
def | errMsg (self) |
|
def | validation (self) |
|
def | validation (self, value) |
|
def | hasValidated (self) |
|
def | isValidated (self) |
|
def | first (self) |
|
def | preExeStartTimes (self) |
|
def | exeStartTimes (self) |
|
def | exeStopTimes (self) |
|
def | valStartTimes (self) |
|
def | valStopTimes (self) |
|
def | preExeCpuTime (self) |
|
def | preExeWallTime (self) |
|
def | cpuTime (self) |
|
def | usrTime (self) |
|
def | sysTime (self) |
|
def | wallTime (self) |
|
def | memStats (self) |
|
def | memAnalysis (self) |
|
def | postExeCpuTime (self) |
|
def | postExeWallTime (self) |
|
def | validationCpuTime (self) |
|
def | validationWallTime (self) |
|
def | cpuTimeTotal (self) |
|
def | wallTimeTotal (self) |
|
def | eventCount (self) |
|
def | reSimEvent (self) |
|
def | athenaMP (self) |
|
def | dbMonitor (self) |
|
def | setPreExeStart (self) |
|
def | setValStart (self) |
|
def | preExecute (self, input=set(), output=set()) |
|
def | postExecute (self) |
|
def | validate (self) |
|
def | doAll (self, input=set(), output=set()) |
| Convenience function. More...
|
|
Definition at line 573 of file trfExe.py.
◆ __init__()
def python.trfExe.echoExecutor.__init__ |
( |
|
self, |
|
|
|
name = 'Echo' , |
|
|
|
trf = None |
|
) |
| |
Definition at line 574 of file trfExe.py.
574 def __init__(self, name = 'Echo', trf = None):
577 super(echoExecutor, self).
__init__(name=name, trf=trf)
◆ athenaMP()
def python.trfExe.transformExecutor.athenaMP |
( |
|
self | ) |
|
|
inherited |
Definition at line 452 of file trfExe.py.
453 return self._athenaMP
◆ cpuTime()
def python.trfExe.transformExecutor.cpuTime |
( |
|
self | ) |
|
|
inherited |
Definition at line 366 of file trfExe.py.
367 if self._exeStart
and self._exeStop:
◆ cpuTimeTotal()
def python.trfExe.transformExecutor.cpuTimeTotal |
( |
|
self | ) |
|
|
inherited |
Definition at line 430 of file trfExe.py.
430 def cpuTimeTotal(self):
431 if self._preExeStart
and self._valStop:
432 return calcCpuTime(self._preExeStart, self._valStop)
◆ dbMonitor()
def python.trfExe.transformExecutor.dbMonitor |
( |
|
self | ) |
|
|
inherited |
Definition at line 456 of file trfExe.py.
457 return self._dbMonitor
◆ doAll()
def python.trfExe.transformExecutor.doAll |
( |
|
self, |
|
|
|
input = set() , |
|
|
|
output = set() |
|
) |
| |
|
inherited |
Convenience function.
Definition at line 499 of file trfExe.py.
499 def doAll(self, input=set(), output=
set()):
500 self.preExecute(input, output)
◆ errMsg()
def python.trfExe.transformExecutor.errMsg |
( |
|
self | ) |
|
|
inherited |
◆ eventCount()
def python.trfExe.transformExecutor.eventCount |
( |
|
self | ) |
|
|
inherited |
Definition at line 444 of file trfExe.py.
444 def eventCount(self):
445 return self._eventCount
◆ execute()
def python.trfExe.echoExecutor.execute |
( |
|
self | ) |
|
Reimplemented from python.trfExe.transformExecutor.
Definition at line 580 of file trfExe.py.
581 self._exeStart = os.times()
582 msg.debug(
'exeStart time is {0}'.
format(self._exeStart))
583 msg.info(
'Starting execution of %s', self._name)
584 msg.info(
'Transform argument dictionary now follows:')
585 for k, v
in self.conf.argdict.items():
586 print(
"%s = %s" % (k, v))
587 self._hasExecuted =
True
590 msg.info(
'%s executor returns %d', self._name, self._rc)
591 self._exeStop = os.times()
592 msg.debug(
'exeStop time is {0}'.
format(self._exeStop))
◆ exeStartTimes()
def python.trfExe.transformExecutor.exeStartTimes |
( |
|
self | ) |
|
|
inherited |
Definition at line 336 of file trfExe.py.
336 def exeStartTimes(self):
337 return self._exeStart
◆ exeStopTimes()
def python.trfExe.transformExecutor.exeStopTimes |
( |
|
self | ) |
|
|
inherited |
Definition at line 340 of file trfExe.py.
340 def exeStopTimes(self):
◆ extraMetadata()
def python.trfExe.transformExecutor.extraMetadata |
( |
|
self | ) |
|
|
inherited |
Definition at line 292 of file trfExe.py.
292 def extraMetadata(self):
293 return self._extraMetadata
◆ first()
def python.trfExe.transformExecutor.first |
( |
|
self | ) |
|
|
inherited |
- Note
- At the moment only athenaExecutor sets this property, but that might be changed...
Definition at line 325 of file trfExe.py.
326 if hasattr(self,
'_first'):
◆ hasExecuted()
def python.trfExe.transformExecutor.hasExecuted |
( |
|
self | ) |
|
|
inherited |
Definition at line 296 of file trfExe.py.
296 def hasExecuted(self):
297 return self._hasExecuted
◆ hasValidated()
def python.trfExe.transformExecutor.hasValidated |
( |
|
self | ) |
|
|
inherited |
Definition at line 316 of file trfExe.py.
316 def hasValidated(self):
317 return self._hasValidated
◆ inData() [1/2]
def python.trfExe.transformExecutor.inData |
( |
|
self | ) |
|
|
inherited |
◆ inData() [2/2]
def python.trfExe.transformExecutor.inData |
( |
|
self, |
|
|
|
value |
|
) |
| |
|
inherited |
Definition at line 242 of file trfExe.py.
242 def inData(self, value):
243 self._inData =
set(value)
◆ inDataUpdate()
def python.trfExe.transformExecutor.inDataUpdate |
( |
|
self, |
|
|
|
value |
|
) |
| |
|
inherited |
Definition at line 245 of file trfExe.py.
245 def inDataUpdate(self, value):
247 if '_inData' in dir(self):
248 self._inData.update(value)
◆ input()
def python.trfExe.transformExecutor.input |
( |
|
self | ) |
|
|
inherited |
- Note
- This returns the actual input data with which this executor ran (c.f.
inData
which returns all the possible data types this executor could run with)
Definition at line 276 of file trfExe.py.
278 if '_input' in dir(self):
◆ isValidated()
def python.trfExe.transformExecutor.isValidated |
( |
|
self | ) |
|
|
inherited |
Definition at line 320 of file trfExe.py.
320 def isValidated(self):
321 return self._isValidated
◆ memAnalysis()
def python.trfExe.transformExecutor.memAnalysis |
( |
|
self | ) |
|
|
inherited |
Definition at line 398 of file trfExe.py.
398 def memAnalysis(self):
399 return self._memLeakResult
◆ memStats()
def python.trfExe.transformExecutor.memStats |
( |
|
self | ) |
|
|
inherited |
Definition at line 394 of file trfExe.py.
395 return self._memStats
◆ myMerger()
def python.trfExe.transformExecutor.myMerger |
( |
|
self | ) |
|
|
inherited |
Now define properties for these data members.
Definition at line 207 of file trfExe.py.
208 return self._myMerger
◆ name() [1/2]
def python.trfExe.transformExecutor.name |
( |
|
self | ) |
|
|
inherited |
◆ name() [2/2]
def python.trfExe.transformExecutor.name |
( |
|
self, |
|
|
|
value |
|
) |
| |
|
inherited |
◆ outData() [1/2]
def python.trfExe.transformExecutor.outData |
( |
|
self | ) |
|
|
inherited |
◆ outData() [2/2]
def python.trfExe.transformExecutor.outData |
( |
|
self, |
|
|
|
value |
|
) |
| |
|
inherited |
Definition at line 262 of file trfExe.py.
262 def outData(self, value):
263 self._outData =
set(value)
◆ outDataUpdate()
def python.trfExe.transformExecutor.outDataUpdate |
( |
|
self, |
|
|
|
value |
|
) |
| |
|
inherited |
Definition at line 265 of file trfExe.py.
265 def outDataUpdate(self, value):
267 if '_outData' in dir(self):
268 self._outData.update(value)
◆ output()
def python.trfExe.transformExecutor.output |
( |
|
self | ) |
|
|
inherited |
- Note
- This returns the actual output data with which this executor ran (c.f.
outData
which returns all the possible data types this executor could run with)
Definition at line 285 of file trfExe.py.
287 if '_output' in dir(self):
◆ postExeCpuTime()
def python.trfExe.transformExecutor.postExeCpuTime |
( |
|
self | ) |
|
|
inherited |
Definition at line 402 of file trfExe.py.
402 def postExeCpuTime(self):
403 if self._exeStop
and self._valStart:
◆ postExecute()
def python.trfExe.transformExecutor.postExecute |
( |
|
self | ) |
|
|
inherited |
◆ postExeWallTime()
def python.trfExe.transformExecutor.postExeWallTime |
( |
|
self | ) |
|
|
inherited |
Definition at line 409 of file trfExe.py.
409 def postExeWallTime(self):
410 if self._exeStop
and self._valStart:
◆ preExeCpuTime()
def python.trfExe.transformExecutor.preExeCpuTime |
( |
|
self | ) |
|
|
inherited |
Definition at line 352 of file trfExe.py.
352 def preExeCpuTime(self):
353 if self._preExeStart
and self._exeStart:
354 return calcCpuTime(self._preExeStart, self._exeStart)
◆ preExecute()
def python.trfExe.transformExecutor.preExecute |
( |
|
self, |
|
|
|
input = set() , |
|
|
|
output = set() |
|
) |
| |
|
inherited |
Reimplemented in python.trfExe.archiveExecutor, python.trfExe.bsMergeExecutor, python.trfExe.NTUPMergeExecutor, python.trfExe.DQMPostProcessExecutor, python.trfExe.DQMergeExecutor, python.trfExe.reductionFrameworkExecutor, python.trfExe.POOLMergeExecutor, python.trfExe.athenaExecutor, python.trfExe.scriptExecutor, and python.trfExe.logscanExecutor.
Definition at line 471 of file trfExe.py.
471 def preExecute(self, input = set(), output =
set()):
472 self.setPreExeStart()
473 msg.info(
'Preexecute for %s', self._name)
◆ preExeStartTimes()
def python.trfExe.transformExecutor.preExeStartTimes |
( |
|
self | ) |
|
|
inherited |
Definition at line 332 of file trfExe.py.
332 def preExeStartTimes(self):
333 return self._preExeStart
◆ preExeWallTime()
def python.trfExe.transformExecutor.preExeWallTime |
( |
|
self | ) |
|
|
inherited |
Definition at line 359 of file trfExe.py.
359 def preExeWallTime(self):
360 if self._preExeStart
and self._exeStart:
◆ rc()
def python.trfExe.transformExecutor.rc |
( |
|
self | ) |
|
|
inherited |
◆ reSimEvent()
def python.trfExe.transformExecutor.reSimEvent |
( |
|
self | ) |
|
|
inherited |
Definition at line 448 of file trfExe.py.
448 def reSimEvent(self):
449 return self._resimevents
◆ setPreExeStart()
def python.trfExe.transformExecutor.setPreExeStart |
( |
|
self | ) |
|
|
inherited |
Definition at line 461 of file trfExe.py.
461 def setPreExeStart(self):
462 if self._preExeStart
is None:
463 self._preExeStart = os.times()
464 msg.debug(
'preExeStart time is {0}'.
format(self._preExeStart))
◆ setValStart()
def python.trfExe.transformExecutor.setValStart |
( |
|
self | ) |
|
|
inherited |
Definition at line 466 of file trfExe.py.
466 def setValStart(self):
467 if self._valStart
is None:
468 self._valStart = os.times()
469 msg.debug(
'valStart time is {0}'.
format(self._valStart))
◆ substep()
def python.trfExe.transformExecutor.substep |
( |
|
self | ) |
|
|
inherited |
◆ sysTime()
def python.trfExe.transformExecutor.sysTime |
( |
|
self | ) |
|
|
inherited |
Definition at line 380 of file trfExe.py.
381 if self._exeStart
and self._exeStop:
382 return self._exeStop[3] - self._exeStart[3]
◆ trf() [1/2]
def python.trfExe.transformExecutor.trf |
( |
|
self | ) |
|
|
inherited |
◆ trf() [2/2]
def python.trfExe.transformExecutor.trf |
( |
|
self, |
|
|
|
value |
|
) |
| |
|
inherited |
◆ usrTime()
def python.trfExe.transformExecutor.usrTime |
( |
|
self | ) |
|
|
inherited |
Definition at line 373 of file trfExe.py.
374 if self._exeStart
and self._exeStop:
375 return self._exeStop[2] - self._exeStart[2]
◆ validate()
def python.trfExe.transformExecutor.validate |
( |
|
self | ) |
|
|
inherited |
◆ validation() [1/2]
def python.trfExe.transformExecutor.validation |
( |
|
self | ) |
|
|
inherited |
Definition at line 308 of file trfExe.py.
309 return self._validation
◆ validation() [2/2]
def python.trfExe.transformExecutor.validation |
( |
|
self, |
|
|
|
value |
|
) |
| |
|
inherited |
Definition at line 312 of file trfExe.py.
313 self._validation = value
◆ validationCpuTime()
def python.trfExe.transformExecutor.validationCpuTime |
( |
|
self | ) |
|
|
inherited |
Definition at line 416 of file trfExe.py.
416 def validationCpuTime(self):
417 if self._valStart
and self._valStop:
◆ validationWallTime()
def python.trfExe.transformExecutor.validationWallTime |
( |
|
self | ) |
|
|
inherited |
Definition at line 423 of file trfExe.py.
423 def validationWallTime(self):
424 if self._valStart
and self._valStop:
◆ valStartTimes()
def python.trfExe.transformExecutor.valStartTimes |
( |
|
self | ) |
|
|
inherited |
Definition at line 344 of file trfExe.py.
344 def valStartTimes(self):
345 return self._valStart
◆ valStopTimes()
def python.trfExe.transformExecutor.valStopTimes |
( |
|
self | ) |
|
|
inherited |
Definition at line 348 of file trfExe.py.
348 def valStopTimes(self):
◆ wallTime()
def python.trfExe.transformExecutor.wallTime |
( |
|
self | ) |
|
|
inherited |
Definition at line 387 of file trfExe.py.
388 if self._exeStart
and self._exeStop:
◆ wallTimeTotal()
def python.trfExe.transformExecutor.wallTimeTotal |
( |
|
self | ) |
|
|
inherited |
Definition at line 437 of file trfExe.py.
437 def wallTimeTotal(self):
438 if self._preExeStart
and self._valStop:
◆ _alreadyInContainer
python.trfExe.transformExecutor._alreadyInContainer |
|
privateinherited |
◆ _athenaConcurrentEvents
python.trfExe.transformExecutor._athenaConcurrentEvents |
|
privateinherited |
◆ _athenaMP
python.trfExe.transformExecutor._athenaMP |
|
privateinherited |
◆ _athenaMT
python.trfExe.transformExecutor._athenaMT |
|
privateinherited |
◆ _containerSetup
python.trfExe.transformExecutor._containerSetup |
|
privateinherited |
◆ _dbMonitor
python.trfExe.transformExecutor._dbMonitor |
|
privateinherited |
◆ _errMsg
python.trfExe.echoExecutor._errMsg |
|
private |
◆ _eventCount
python.trfExe.transformExecutor._eventCount |
|
privateinherited |
◆ _exeStart
python.trfExe.echoExecutor._exeStart |
|
private |
◆ _exeStop
python.trfExe.echoExecutor._exeStop |
|
private |
◆ _extraMetadata
python.trfExe.transformExecutor._extraMetadata |
|
privateinherited |
◆ _hasExecuted
python.trfExe.echoExecutor._hasExecuted |
|
private |
◆ _hasValidated
python.trfExe.transformExecutor._hasValidated |
|
privateinherited |
◆ _inData
python.trfExe.transformExecutor._inData |
|
privateinherited |
◆ _isValidated
python.trfExe.transformExecutor._isValidated |
|
privateinherited |
◆ _memFullFile
python.trfExe.transformExecutor._memFullFile |
|
privateinherited |
◆ _memLeakResult
python.trfExe.transformExecutor._memLeakResult |
|
privateinherited |
◆ _memStats
python.trfExe.transformExecutor._memStats |
|
privateinherited |
◆ _myMerger
python.trfExe.transformExecutor._myMerger |
|
privateinherited |
◆ _name
python.trfExe.transformExecutor._name |
|
privateinherited |
◆ _outData
python.trfExe.transformExecutor._outData |
|
privateinherited |
◆ _preExeStart
python.trfExe.transformExecutor._preExeStart |
|
privateinherited |
- Note
- Place holders for resource consumption. CPU and walltime are available for all executors but currently only athena is instrumented to fill in memory stats (and then only if PerfMonSD is enabled).
Definition at line 186 of file trfExe.py.
◆ _rc
python.trfExe.echoExecutor._rc |
|
private |
◆ _resimevents
python.trfExe.transformExecutor._resimevents |
|
privateinherited |
◆ _trf
python.trfExe.transformExecutor._trf |
|
privateinherited |
◆ _validation
python.trfExe.transformExecutor._validation |
|
privateinherited |
◆ _valStart
python.trfExe.transformExecutor._valStart |
|
privateinherited |
◆ _valStop
python.trfExe.transformExecutor._valStop |
|
privateinherited |
◆ conf
python.trfExe.transformExecutor.conf |
|
inherited |
Executor configuration:
- Note
- that if conf and trf are
None
then we'll probably set the conf up later (this is allowed and expected to be done once the master transform has figured out what it's doing for this job)
Definition at line 163 of file trfExe.py.
◆ inData
python.trfExe.transformExecutor.inData |
|
inherited |
- Note
- Protect against _inData not yet being defined
-
Use normal setter
Definition at line 251 of file trfExe.py.
◆ outData
python.trfExe.transformExecutor.outData |
|
inherited |
- Note
- Protect against _outData not yet being defined
-
Use normal setter
Definition at line 271 of file trfExe.py.
The documentation for this class was generated from the following file:
constexpr std::enable_if_t< is_bitmask_v< E >, E & > set(E &lhs, E rhs)
Convenience function to set bits in a class enum bitmask.