tools Namespace Reference

Functions
def	addCrabInputFile
def	copyFilesFromCastor
def	copyFilesLocal
def	create_single_iov_db
def	dqmWorkflowName
def	getDatasetStr
def	haddInCastor
def	haddLocal
def	listFilesInCastor
def	listFilesLocal
def	loadCmsProcess
def	loadCmsProcessFile
def	loadCrabCfg
def	loadCrabDefault
def	parseInput
def	prependPaths
def	replaceTemplate
def	run_checked
def	setGridEnv
def	writeCfg
def	writeCfgPkl

Function Documentation

def tools.addCrabInputFile	(		crabCfg,
			inputFile
	)

Definition at line 183 of file tools.py.

Referenced by DTDQMValidation.DTDQMValidation.initCrab(), DTAnalysisResiduals.DTAnalysisResiduals.initCrab(), DTTTrigValid.DTTTrigValid.initCrab(), DTResidualCalibration.DTResidualCalibration.initCrab(), DTVDriftSegmentCalibration.DTVDriftSegmentCalibration.initCrab(), and DTVDriftMeanTimerCalibration.DTVDriftMeanTimerCalibration.initCrab().

def tools.copyFilesFromCastor	(		castor_dir,
			output_dir,
			type = 'root'
	)

Definition at line 55 of file tools.py.

def tools.copyFilesLocal	(		dir,
			output_dir,
			type = 'root'
	)

Definition at line 68 of file tools.py.

def tools.create_single_iov_db	(		global_tag,
			run_number,
			output_db
	)

Create an sqlite file with single-IOV tags for alignment payloads.

Arguments:
- `global_tag`: global tag from which to extract the payloads
- `run_number`: run for which the IOVs are selected
- `output_db`: name of the output sqlite file

Definition at line 7 of file tools.py.

References shell.connect(), join(), and run_checked().

def create_single_iov_db(global_tag, run_number, output_db):
    """Create an sqlite file with single-IOV tags for alignment payloads.

    Arguments:
    - `global_tag`: global tag from which to extract the payloads
    - `run_number`: run for which the IOVs are selected
    - `output_db`: name of the output sqlite file
    """

    con = shell.connect()
    tags = con.global_tag_map(global_tag_name = global_tag,
                              record = ["TrackerAlignmentRcd",
                                        "TrackerSurfaceDeformationRcd",
                                        "TrackerAlignmentErrorExtendedRcd"])
    con.close_session()

    tags = {item["record"]: {"name": item["tag_name"]}
            for item in tags.as_dicts()}

    for record,tag in tags.iteritems():
        iovs = con.tag(name = tag["name"]).iovs().as_dicts()
        run_is_covered = False
        for iov in reversed(iovs):
            if iov["since"] <= run_number:
                tag["since"] = str(iov["since"])
                run_is_covered = True
                break
        if not run_is_covered:
            msg = ("Run number {0:d} is not covered in '{1:s}' ({2:s}) from"
                   " '{3:s}'.".format(run_number, tag["name"], record,
                                      global_tag))
            print msg
            print "Aborting..."
            sys.exit(1)

    result = {}
    if os.path.exists(output_db): os.remove(output_db)
    for record,tag in tags.iteritems():
        result[record] = {"connect": "sqlite_file:"+output_db,
                          "tag": "_".join([tag["name"], tag["since"]])}
        cmd = ("conddb_import",
               "-f", "frontier://PromptProd/cms_conditions",
               "-c", result[record]["connect"],
               "-i", tag["name"],
               "-t", result[record]["tag"],
               "-b", str(run_number),
               "-e", str(run_number))
        run_checked(cmd)
    run_checked(["sqlite3", output_db, "update iov set since=1"])

    return result