SiStripDAQPopCon Namespace Reference

Functions
def	main
def	runjob

Variables
string	cfg_template = 'CondTools/SiStrip/python/SiStripO2O_cfg_template.py'
string	jobDirVar = 'JOBDIR'

Function Documentation

def SiStripDAQPopCon.main

(

)

Definition at line 122 of file SiStripDAQPopCon.py.

References runjob(), and submitPVValidationJobs.split().

def main():
    parser = argparse.ArgumentParser(description='Run a single O2O job for SiStrip DAQ and upload the payloads to condition database.')
    parser.add_argument('analyzer', metavar='ANALYZER', help='Which EDAnalyzer to use to create the payload.')
    parser.add_argument('since', metavar='SINCE', type=str, help='Run number.')
    parser.add_argument('cfgfile', metavar='CFGLINES', help='File containing configuration lines.')
    parser.add_argument('--destTags', required=True, help='Destination tag name(s) for upload. Use comma to separate multiple values.')
    parser.add_argument('--destDb', required=True, help='Destination DB to upload.')
    parser.add_argument('--inputTag', required=True, help='Tag name to be used in the sqlite file.')
    parser.add_argument('--condDbRead', default='oracle://cms_orcon_prod/CMS_CONDITIONS', help='Connection string for the DB from which the fast O2O retrives payloads.')
    parser.add_argument('--hashmapDb', default='', help='DB to read and write config-to-payload hash (for fast O2O).')
    parser.add_argument('--skiplistFile', default='', help='File containing the devices to be skipped in G1 O2O.')
    parser.add_argument('--whitelistFile', default='', help='File of the whitelisted devices in G1 O2O.')

    parser.add_argument('--no-upload', action="store_true", default=False, help='Do not upload payload. Default: %(default)s.')
    parser.add_argument('--use-uploader', action="store_true", default=False, help='Use conditionUploader instead of conddb copy. Default: %(default)s.')
    parser.add_argument('--bookkeeping-db', default='prod', choices=['prod', 'dev', 'private'], help='Bookkeeping database for fast O2O and G1 O2O. Default: %(default)s.')
    parser.add_argument('--debug', action="store_true", default=False, help='Switch on debug mode. Default: %(default)s.')
    args = parser.parse_args()

    loglevel = logging.INFO
    if args.debug:
        loglevel = logging.DEBUG
        if args.bookkeeping_db == 'prod':
            args.bookkeeping_db = 'dev'
    logging.basicConfig(level=loglevel, format='[%(asctime)s] %(levelname)s: %(message)s')

    if not args.since.isdigit():
        raise RuntimeError('Since (=%s) must be a valid run number!'%(args.since))

    args.destTags = args.destTags.strip().split(',')

    logging.info('Running O2O %s on machine [%s]' % (args.analyzer, socket.gethostname()))

    try:
        jobdirbase = os.environ[jobDirVar]
    except KeyError:
        jobdirbase = '/tmp'
        logging.warning('%s not set in env, will use %s' % (jobDirVar, jobdirbase))

    # change filepaths in args to abs path
    args.cfgfile = os.path.abspath(args.cfgfile)
    if args.skiplistFile:
        args.skiplistFile = os.path.abspath(args.skiplistFile)
    if args.whitelistFile:
        args.whitelistFile = os.path.abspath(args.whitelistFile)

    # change to O2O working directory
    jobdir = os.path.join(jobdirbase, args.since, args.analyzer)
    if not os.path.exists(jobdir):
        os.makedirs(jobdir)
    os.chdir(jobdir)
    logging.info('Running O2O in %s' % jobdir)

    # run job and upload
    runjob(args)

    logging.info('Done!')