BulkRunFollowup.BulkRunFollowup Class Reference

Collaboration diagram for BulkRunFollowup.BulkRunFollowup:

Public Member Functions
def	__init__ (self, allowedRuns, inputPattern="/raid02/schernau/ped/csc/*.data", processedFilesList="ProcessedFiles_Followup.list", outputDirBase="/raid02/lampen/datasets/csc/PedProcessing", debug=False, allowDirOverwrite=False)
def	run (self, numToRun=10)
def	ReadProcessedFilesList (self)
def	AddProcessedFiles (self, newFiles)
def	FindFiles (self)
def	RunAthena (self, pattern, runNumber)

Public Attributes
	AllowedRuns
	InputPattern
	ProcessedFilesList
	OutputDirBase
	debug
	AllowDirOverwrite

Detailed Description

Run on multiple pedestal files

#Used to run on multiple pedestal bytestream files located somewhere on disk.
#Puts results into seperate directories by run-number. It extracts pertinent
#information from the file names, which are expected to be of the form:

Quickie folowup when BulkRun failed on a few. This will re-enter existing directories 
of particular run numbers. It should be given a sepearte processedFiles.list

data10_calib.00157081.calibration_pedCSC.daq.RAW._lb0000._CSC-EB._0001.data

run() - run over all runs
ReadProcessedFilesList() - find all files already run on from a local text file
AddProcessedFiles() - save newly run on files to disk
FindFiles() - Find pattern and run number of a set of files that have not yet been run on
RunAthena() - run athena job for a set of runs

Definition at line 10 of file BulkRunFollowup.py.

Constructor & Destructor Documentation

__init__()

def BulkRunFollowup.BulkRunFollowup.__init__	(		self,
			allowedRuns,
			inputPattern = "/raid02/schernau/ped/csc/*.data",
			processedFilesList = "ProcessedFiles_Followup.list",
			outputDirBase = "/raid02/lampen/datasets/csc/PedProcessing",
			debug = False,
			allowDirOverwrite = False
	)

initialize internal variables

Definition at line 29 of file BulkRunFollowup.py.

  def __init__(
      self,
      allowedRuns,
      inputPattern = "/raid02/schernau/ped/csc/*.data",
      processedFilesList = "ProcessedFiles_Followup.list",
      outputDirBase = "/raid02/lampen/datasets/csc/PedProcessing",
      debug = False,
      allowDirOverwrite = False,
      ):
    """initialize internal variables"""
    self.AllowedRuns = allowedRuns
    self.InputPattern = inputPattern
    self.ProcessedFilesList = processedFilesList
    self.OutputDirBase = outputDirBase
    self.debug = debug
    self.AllowDirOverwrite = allowDirOverwrite
 

Member Function Documentation

AddProcessedFiles()

def BulkRunFollowup.BulkRunFollowup.AddProcessedFiles	(		self,
			newFiles
	)

Save new processed files to disk

Definition at line 98 of file BulkRunFollowup.py.

  def AddProcessedFiles(self,newFiles):
    """Save new processed files to disk"""
    ProcessedFiles = self.ReadProcessedFilesList()
    print ("Got old processed files")
    print (ProcessedFiles)
    ProcessedFiles += newFiles
    print ("New version:")
    print (ProcessedFiles)
    f = open(self.ProcessedFilesList,"wb")
    pickle.dump(ProcessedFiles,f)
    f.close()
 
    return True
 
 

FindFiles()

def BulkRunFollowup.BulkRunFollowup.FindFiles

(

self

)

Definition at line 114 of file BulkRunFollowup.py.

  def FindFiles(self):
 
    #Initial setup
    FoundUnprocessedFile = False
 
    #Get processed file list
    ProcessedFiles = self.ReadProcessedFilesList()
 
    #Get list of files in input dir
    inputFiles = glob(self.InputPattern)
 
    if(self.debug):
      print()
      print ("Searching for file")
      print ("InputPattern: " + self.InputPattern)
 
    pattern = ""
    runNumber = ""
 
    #Loop through list until find file that is 
    for file in inputFiles:
      if not ProcessedFiles.count(file):
 
        index = file.find("data10")
        if(index ==-1):
          index = file.find("data11")
        if(index == -1):
          print ("ERROR! Index of -1 searching for data1X prefix in filename:")
          print (file)
          raise Exception("Index error") 
        FoundUnprocessedFile = True
        pattern = file[0:index + 22] + "*" #includes run number
        runNumber = file[index + 13: index + 21]
 
    if(not FoundUnprocessedFile):
      if(self.debug):
        print ("Did not find unprocessed file")
      return "",""
 
    if(self.debug) : 
      print ("Found unprocessed file with pattern: " + pattern)
      print ("This includes files:")
      print (glob(pattern))
 
    return pattern, runNumber
 

ReadProcessedFilesList()

def BulkRunFollowup.BulkRunFollowup.ReadProcessedFilesList

(

self

)

Definition at line 84 of file BulkRunFollowup.py.

  def ReadProcessedFilesList(self):
 
    ProcessedFiles = []
 
    #Get processed files
    f = open(self.ProcessedFilesList,"rb") 
    ProcessedFiles = pickle.load(f)
    f.close()
 
    print ('Processed String: ')
    print (ProcessedFiles)
 
    return ProcessedFiles
 

run()

def BulkRunFollowup.BulkRunFollowup.run	(		self,
			numToRun = 10
	)

Run over all run numbers, find files for each, and submit each set to
CscCalcPedMon.py

Definition at line 46 of file BulkRunFollowup.py.

  def run(self, numToRun = 10) :
    """
    Run over all run numbers, find files for each, and submit each set to
    CscCalcPedMon.py
    """
 
    print ("Running on " + str(numToRun) + " runsSet.")
 
 
    runNumbers = []
    for runCnt in range(numToRun) :
      print (">>>>Running on runSet " + str(runCnt+1) + " of " + str(numToRun))
      pattern,runNumber = self.FindFiles()
      if(pattern != ""):
        #have files to run on
        if runNumber in self.AllowedRuns:
          runNumbers += [runNumber]
          self.RunAthena(pattern,runNumber)
        else:
          if(self.debug):
            print ("Skipping file from runNumber " + str(runNumber) + " (Not allowed)")
          #Add files we're skipping into file list
          newProcessedFiles = glob(pattern)
          self.AddProcessedFiles(newProcessedFiles)
 
      else:
        print ("No more unprocessed files. Congrats!")
        print ("N runs done: " + str(runCnt +1))
        print (runNumbers)
        return
    print ("finished all " + str(numToRun) )
    print ("Run numbers include:")
    print (runNumbers)
    print()
    print ("All Processed files:" )
    print (self.ReadProcessedFilesList())
 

RunAthena()

def BulkRunFollowup.BulkRunFollowup.RunAthena	(		self,
			pattern,
			runNumber
	)

Run athena on a particular set of files matching pattern

Definition at line 160 of file BulkRunFollowup.py.

  def RunAthena(self, pattern, runNumber):
    """Run athena on a particular set of files matching pattern"""
    outputDirPath = self.OutputDirBase + "/" + runNumber
      
    if(self.AllowDirOverwrite):
      subprocess.call("rm -rf " + outputDirPath)
 
    print ("Making directory" + outputDirPath)
    #Create output directory
    os.mkdir(outputDirPath,0o755)
 
    #Athena options
    athOpt = "outputPre='" + outputDirPath +"/" + runNumber 
    athOpt += "';inputPat='" + pattern 
    athOpt += "';reportPrefix='runNumber = " 
    athOpt += runNumber + "'"
 
    #athena arguments
    athArgs = ["athena.py", "-c", athOpt, "CscCalcPedMon.py"]
 
    #Output log file
    logFile = open(outputDirPath + "/run2.log","w")
 
    print()
    print ("**************************************")
    print ("Starting running on run " + str(runNumber))
    sys.stdout.flush()
    subprocess.Popen(athArgs,stdout=logFile,stderr=subprocess.STDOUT).wait()
    print ("Finished run " + str(runNumber))
    print ("**************************************")
    print()
 
    logFile.close()
 
    #Add files we just ran on to file list
    newProcessedFiles = glob(pattern)
    self.AddProcessedFiles(newProcessedFiles)

Member Data Documentation

AllowDirOverwrite

BulkRunFollowup.BulkRunFollowup.AllowDirOverwrite

Definition at line 36 of file BulkRunFollowup.py.

AllowedRuns

BulkRunFollowup.BulkRunFollowup.AllowedRuns

Definition at line 31 of file BulkRunFollowup.py.

debug

BulkRunFollowup.BulkRunFollowup.debug

Definition at line 35 of file BulkRunFollowup.py.

InputPattern

BulkRunFollowup.BulkRunFollowup.InputPattern

Definition at line 32 of file BulkRunFollowup.py.

OutputDirBase

BulkRunFollowup.BulkRunFollowup.OutputDirBase

Definition at line 34 of file BulkRunFollowup.py.

ProcessedFilesList

BulkRunFollowup.BulkRunFollowup.ProcessedFilesList

Definition at line 33 of file BulkRunFollowup.py.

---

The documentation for this class was generated from the following file:

• BulkRunFollowup.py