HltComparatorCreateWorkflow Namespace Reference

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)

Function Documentation

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

def HltComparatorCreateWorkflow.ConvertHltOnlineToOffline	(		config,
			frontierString
	)

Definition at line 56 of file HltComparatorCreateWorkflow.py.

References edm.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

def HltComparatorCreateWorkflow.CreateAnalysisConfig	(		analysis,
			hltInclude
	)

Definition at line 146 of file HltComparatorCreateWorkflow.py.

References CheckEnvironment(), FormatHltCff(), GetHltConfiguration(), GetHltKeyForRun(), and edm.print().

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

def HltComparatorCreateWorkflow.FormatHltCff

(

cffPath

)

Definition at line 132 of file HltComparatorCreateWorkflow.py.

Referenced by CreateAnalysisConfig().

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

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

def HltComparatorCreateWorkflow.GetHltConfiguration	(		hltKey,
			frontierString
	)

Definition at line 105 of file HltComparatorCreateWorkflow.py.

References ConvertHltOnlineToOffline().

Referenced by CreateAnalysisConfig().

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

def HltComparatorCreateWorkflow.GetHltKeyForRun

(

run

)

Definition at line 128 of file HltComparatorCreateWorkflow.py.

Referenced by CreateAnalysisConfig().

def GetHltKeyForRun(run):
   raise SystemExit("Not implemented yet")

# Formats an HLT CFF path into a suitable python include statement

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