NTUPMerge_tf Namespace Reference

Functions
	main ()
	getTransform ()

Function Documentation

getTransform()

NTUPMerge_tf.getTransform

(

)

Definition at line 34 of file NTUPMerge_tf.py.

def getTransform():
    msg.debug("in getTransform...")
 
    # get the default executor list
    executorSet = set()
    # instantiate a transform with no steps
    trf = transform(executor = executorSet, description = 'ATLAS NTUPLE merge and post-processing transform')
    
    # add custom merge and post-processing steering parameters for PhysVal
    addPhysValidationMergeFiles(trf.parser)
 
    # additional formats
    addExtraDPDTypes(trf.parser, transform=trf, NTUPMergerArgs = True)
 
    args = trf.parser.parse_args()
    msg.debug("args:", args)
 
    # executor steps
    mergeStepSet = set()
 
    # Check the user's optional parameters
    # NOTE: we need to first check if the arg is present, 
    # then we get the value. When not specified, in fact, 
    # the optional args are not present in the list of
    # args. Also, if we only check its existence,
    # we don't get its value when set with set()
    skipPP = args.skipPostProcessing if 'skipPostProcessing' in args else False
 
    # add to the transform the merge and 
    # post-processing steps conditionally 
    # based on user's input
    addNTUPMergeSubsteps(mergeStepSet, skip_post_processing = skipPP)
 
    trf.appendToExecutorSet(list(mergeStepSet))
 
    return trf
 

main()

NTUPMerge_tf.main

(

)

Definition at line 21 of file NTUPMerge_tf.py.

def main():
    msg.info('This is %s', sys.argv[0])
    if sys.argv[1:] == []:
        msg.info("%s stopped at %s, no input parameters given", sys.argv[0], time.asctime())
    
    trf = getTransform()
    trf.parseCmdLineArgs(sys.argv[1:])
    trf.execute()
    trf.generateReport()
 
    msg.info("%s stopped at %s, tf exit code %d", sys.argv[0], time.asctime(), trf.exitCode)
    sys.exit(trf.exitCode)