python.trfFileValidationFunctions Namespace Reference

Functions
	returnIntegrityOfPOOLFile (fname, **kwargs)
	Integrity function for file class argPOOLFile, argHITSFile, argRDOFile and argEVNTFile.
	returnIntegrityOfNTUPFile (fname)
	Integrity function for file class argNTUPFile.
	returnIntegrityOfBSFile (fname)
	Integrity function for file class argBSFile.
	returnIntegrityOfHISTFile (fname)
	Integrity function for file class argHISTFile.

Variables
	msg = logging.getLogger(__name__)

Function Documentation

returnIntegrityOfBSFile()

python.trfFileValidationFunctions.returnIntegrityOfBSFile

(

fname

)

Integrity function for file class argBSFile.

Definition at line 45 of file trfFileValidationFunctions.py.

def returnIntegrityOfBSFile(fname):
    try:
        from PyJobTransforms.trfUtils import call
        rc = call(["AtlListBSEvents", "-c", fname],
            logger = msg,
            message = "Report by AtlListBSEvents: ",
            timeout = None
        )
    except trfExceptions.TransformTimeoutException:
        return False
    if rc == 0:
        return (True, "integrity of {fileName} good".format(fileName = str(fname)))
    else:
        return (False, "integrity of {fileName} bad: return code: {integrityStatus}".format(fileName = str(fname), integrityStatus = rc))
 

returnIntegrityOfHISTFile()

python.trfFileValidationFunctions.returnIntegrityOfHISTFile

(

fname

)

Integrity function for file class argHISTFile.

Definition at line 61 of file trfFileValidationFunctions.py.

def returnIntegrityOfHISTFile(fname):
    rc = 0 # (default behaviour)
    if rc == 0:
        return (True, "integrity of {fileName} good".format(fileName = str(fname)))
    else:
        return (False, "integrity of {fileName} bad: return code: {integrityStatus}".format(fileName = str(fname), integrityStatus = rc))

returnIntegrityOfNTUPFile()

python.trfFileValidationFunctions.returnIntegrityOfNTUPFile

(

fname

)

Integrity function for file class argNTUPFile.

Definition at line 36 of file trfFileValidationFunctions.py.

def returnIntegrityOfNTUPFile(fname):
    from PyJobTransforms.trfValidateRootFile import checkFile
    rc = checkFile(fileName = fname, the_type = 'basket', requireTree = False)
    if rc == 0:
        return (True, "integrity of {fileName} good".format(fileName = str(fname)))
    else:
        return (False, "integrity of {fileName} bad: return code: {integrityStatus}".format(fileName = str(fname), integrityStatus = rc))
 

returnIntegrityOfPOOLFile()

python.trfFileValidationFunctions.returnIntegrityOfPOOLFile	(		fname,
		**	kwargs )

Integrity function for file class argPOOLFile, argHITSFile, argRDOFile and argEVNTFile.

Definition at line 14 of file trfFileValidationFunctions.py.

def returnIntegrityOfPOOLFile(fname, **kwargs):
    from PyJobTransforms.trfValidateRootFile import checkFile, msg as logger
    import multiprocessing
 
    level = kwargs.get('level')
    if level is not None:
        if level < msg.getEffectiveLevel():
            msg.setLevel(level)
            msg.debug(f"Set logging level of {msg.name!r} to {logging.getLevelName(level)!r}")
        if level < logger.getEffectiveLevel():
            logger.setLevel(level)
            msg.debug(f"Set logging level of {logger.name!r} to {logging.getLevelName(level)!r}")
 
    msg.debug(f"Current process: {multiprocessing.current_process().name}")
 
    rc = checkFile(fileName=fname, the_type='event', requireTree=False)
    if rc == 0:
        return (True, "integrity of {fileName} good".format(fileName = str(fname)))
    else:
        return (False, "integrity of {fileName} bad: return code: {integrityStatus}".format(fileName = str(fname), integrityStatus = rc))
 

Variable Documentation

msg

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

Definition at line 9 of file trfFileValidationFunctions.py.