Functions
def	CheckEnvironment ()

def	ConvertHltOnlineToOffline (config, frontierString)

def	CreateAnalysisConfig (analysis, hltInclude)

def	FormatHltCff (cffPath)

def	GetHltCompileCode (subsystem, package, hltConfig)

def	GetHltConfiguration (hltKey, frontierString)

def	GetHltKeyForRun (run)

def	RemovePSet (config, pset)

Variables
	anaConfig

	args

	default

	dest

	help

	hltConfig

	hltKey

	jobHash

	metavar

	options

	parser

	usage

Function Documentation

◆ CheckEnvironment()

def HltComparatorCreateWorkflow.CheckEnvironment ( )

Definition at line 49 of file HltComparatorCreateWorkflow.py.

Referenced by CreateAnalysisConfig().

 def CheckEnvironment():
    cwd = os.getcwd()
    t = cwd.split("/")
    if t[-1] != "python":
       raise SystemExit("Must run from a Module/Package/python directory")
 
 # Converts an online HLT configuration into offline suitable format

◆ ConvertHltOnlineToOffline()

def HltComparatorCreateWorkflow.ConvertHltOnlineToOffline	(	config,
		frontierString
	)

Definition at line 56 of file HltComparatorCreateWorkflow.py.

References print(), and RemovePSet().

Referenced by GetHltConfiguration().

 def ConvertHltOnlineToOffline(config, frontierString):
    # Replace the frontier string
    onlineFrontier = re.search('"(frontier:.*)"', config)
    if not onlineFrontier:
       print("WARNING: Could not find Frontier string in HLT configuration. Will ignore.")
    else:
       config = config.replace(onlineFrontier.group(1), frontierString)
 
    # Replace the global tag
    config = config.replace("H::All", "P::All")
 
    # print config -- debugging
    # Remove unwanted PSets
    config = RemovePSet(config, "MessageLogger")
 #   config = RemovePSet(config, "DQMStore")
    config = RemovePSet(config, "DQM")
    config = RemovePSet(config, "FUShmDQMOutputService")
 
    return config
 

◆ CreateAnalysisConfig()

def HltComparatorCreateWorkflow.CreateAnalysisConfig	(	analysis,
		hltInclude
	)

Definition at line 146 of file HltComparatorCreateWorkflow.py.

References CheckEnvironment().

 def CreateAnalysisConfig(analysis, hltInclude):
    anaName = "JobAnalysisConfig_%s_cfg.py" % jobHash
    f = open(analysis)
    g = open(anaName, "w")
    g.write(f.read())
    g.write("\n")
    g.write(hltInclude)
    g.close()
    f.close()
    return anaName
 
 # Quick sanity check of the environment
 CheckEnvironment()
 
 # Get the required HLT config snippet

◆ FormatHltCff()

def HltComparatorCreateWorkflow.FormatHltCff ( cffPath )

Definition at line 132 of file HltComparatorCreateWorkflow.py.

 def FormatHltCff(cffPath):
    pathParts = cffPath.split(".")
    if not re.match("^[_A-Za-z0-9]*\.[_A-Za-z0-9]*\.[_A-Za-z0-9]*$", cffPath):
       raise SystemExit("Expected cff in form Package.Module.configName_cff")
    return 'process.load("%s")' % cffPath
 
 # Returns python code to compile an HLT configuration

◆ GetHltCompileCode()

def HltComparatorCreateWorkflow.GetHltCompileCode	(	subsystem,
		package,
		hltConfig
	)

Definition at line 139 of file HltComparatorCreateWorkflow.py.

 def GetHltCompileCode(subsystem, package, hltConfig):
    tmpCode = compileCode.replace("SUBSYSTEM", subsystem)
    tmpCode = tmpCode.replace("PACKAGE", package)
    tmpCode = tmpCode.replace("CONFIG", hltConfig + "c")
    return tmpCode
 
 # Prepares the analysis configuration

◆ GetHltConfiguration()

def HltComparatorCreateWorkflow.GetHltConfiguration	(	hltKey,
		frontierString
	)

Definition at line 105 of file HltComparatorCreateWorkflow.py.

References ConvertHltOnlineToOffline(), and fileinputsource_cfi.read.

 def GetHltConfiguration(hltKey, frontierString):
    # Format the config path for include
    cwd = os.getcwd()
    t = cwd.split("/")
    module = t[-3]
    package = t[-2]
 
    # Get the HLT config
    config = os.popen2('wget "http://cms-project-confdb-hltdev.web.cern.ch/cms-project-confdb-hltdev/get.jsp?dbName=ORCOFF&configName=%s&cff=&nooutput=&format=Python" -O- -o /dev/null' % hltKey)[1].read()
    #config = os.popen2("edmConfigFromDB --debug --configName %s --orcoff --format Python --nooutput --cff" % hltKey)[1].read() 
    configName = "JobHLTConfig_%s_cff.py" % jobHash
 
    # Perform online --> offline conversion
    config = ConvertHltOnlineToOffline(config, frontierString)
 
    # Write the config
    f = open(configName, "w")
    f.write(config)
    f.close()
 
    return 'process.load("%s.%s.%s")' % (module, package, configName.split(".")[0])
 
 # Fetches the HLT key from ConfDB - turned off in options for now

◆ GetHltKeyForRun()

def HltComparatorCreateWorkflow.GetHltKeyForRun ( run )

Definition at line 128 of file HltComparatorCreateWorkflow.py.

 def GetHltKeyForRun(run):
    raise SystemExit("Not implemented yet")
 
 # Formats an HLT CFF path into a suitable python include statement

◆ RemovePSet()

def HltComparatorCreateWorkflow.RemovePSet	(	config,
		pset
	)

Definition at line 76 of file HltComparatorCreateWorkflow.py.

Referenced by ConvertHltOnlineToOffline().

 def RemovePSet(config, pset):
    startLoc = config.find(pset)
    started = False
    count = 0
    curLoc = startLoc
    endLoc = 0
 
    # Find starting parenthesis
    while not started:
       if config[curLoc] == "(":
          started = True
          count = 1
       curLoc += 1
 
    # Find end parenthesis
    while endLoc == 0:
       if config[curLoc] == "(":
          count += 1
       elif config[curLoc] == ")":
          count -= 1
       if count == 0:
          endLoc = curLoc
       curLoc += 1
 
    config = config.replace(config[startLoc:endLoc + 1], "")
 
    return config
 
 # Fetches the HLT configuration from ConfDB