ATLAS Offline Software
Loading...
Searching...
No Matches
python.trfReports Namespace Reference

Classes

class  machineReport
 Report on the machine where we ran. More...
class  trfExecutorReport
 Class to contain metadata for an executor. More...
class  trfFileReport
 Class to contain metadata for file types. More...
class  trfJobReport
 Class holding a transform job report. More...
class  trfReport
 Base (almost virtual) report from which all real transform reports derive. More...

Functions

 pyJobReportToFileDict (jobReport, io='all')
 Small helper function to extract a per-datatype dictionary from a job report of lists.
 exeResourceReport (exe, report)

Variables

str __version__ = '$Revision: 784023 $'
 msg = logging.getLogger(__name__)
dict defaultFileReport = {'input': 'name', 'temporary': None, 'output': 'full'}
 Default values for file reporting.

Function Documentation

◆ exeResourceReport()

python.trfReports.exeResourceReport ( exe,
report )

Definition at line 636 of file trfReports.py.

636def exeResourceReport(exe, report):
637 exeResource = {'cpuTime': report.roundoff(exe.cpuTime),
638 'wallTime': report.roundoff(exe.wallTime),
639 'preExe': {
640 'cpuTime': report.roundoff(exe.preExeCpuTime),
641 'wallTime': report.roundoff(exe.preExeWallTime),
642 },
643 'postExe': {
644 'cpuTime': report.roundoff(exe.postExeCpuTime),
645 'wallTime': report.roundoff(exe.postExeWallTime),
646 },
647 'validation': {
648 'cpuTime': report.roundoff(exe.validationCpuTime),
649 'wallTime': report.roundoff(exe.validationWallTime),
650 },
651 'total': {
652 'cpuTime': report.roundoff(exe.cpuTimeTotal),
653 'wallTime': report.roundoff(exe.wallTimeTotal),
654 },
655 }
656
657 if exe.memStats:
658 exeResource['memory'] = exe.memStats
659 if exe.memAnalysis:
660 exeResource['memoryAnalysis'] = exe.memAnalysis
661 if exe.eventCount:
662 exeResource['nevents'] = exe.eventCount
663 if exe.name=='ReSim':
664 exeResource['resimevents'] = exe.reSimEvent
665 if exe.athenaMP:
666 exeResource['mpworkers'] = exe.athenaMP
667 exeResource['cpuTimePerWorker'] = report.roundoff(exe.cpuTime/exe.athenaMP)
668 if exe.dbMonitor:
669 exeResource['dbData'] = exe.dbMonitor['bytes']
670 exeResource['dbTime'] = report.roundoff(exe.dbMonitor['time'])
671 report._dbDataTotal += exeResource['dbData']
672 report._dbTimeTotal += exeResource['dbTime']
673 return exeResource

◆ pyJobReportToFileDict()

python.trfReports.pyJobReportToFileDict ( jobReport,
io = 'all' )

Small helper function to extract a per-datatype dictionary from a job report of lists.

Definition at line 624 of file trfReports.py.

624def pyJobReportToFileDict(jobReport, io = 'all'):
625 dataDict = {}
626 if 'files' not in jobReport:
627 msg.warning('Job report has no "files" section')
628 return dataDict
629 for iotype in jobReport['files']:
630 if io == 'all' or io == iotype:
631 for filedata in jobReport['files'][iotype]:
632 dataDict[filedata['type']] = filedata
633 return dataDict
634
635

Variable Documentation

◆ __version__

str python.trfReports.__version__ = '$Revision: 784023 $'
private

Definition at line 11 of file trfReports.py.

◆ defaultFileReport

dict python.trfReports.defaultFileReport = {'input': 'name', 'temporary': None, 'output': 'full'}

Default values for file reporting.

Definition at line 36 of file trfReports.py.

◆ msg

python.trfReports.msg = logging.getLogger(__name__)

Definition at line 27 of file trfReports.py.