CMSSWScenario Namespace Reference

Functions
def	load_CMSSW_scenario (filename)

Variables
int	NUMBEROFEVENTS = 1
int	NUMBEROFEVENTSINFLIGHT = 1
int	NUMBEROFALGOSINFLIGHT = 1000
int	NUMBEROFTHREADS = 1
	CLONEALGOS = False
	DUMPQUEUES = False
int	VERBOSITY = 3
	NumberOfEvents = NUMBEROFEVENTS
	NumberOfEventsInFlight = NUMBEROFEVENTSINFLIGHT
	NumberOfAlgosInFlight = NUMBEROFALGOSINFLIGHT
	NumberOfThreads = NUMBEROFTHREADS
	CloneAlgos = CLONEALGOS
	DumpQueues = DUMPQUEUES
	Verbosity = VERBOSITY
tuple	ms = MessageSvc()
tuple	evtloop = HiveEventLoopMgr()
tuple	app = ApplicationMgr()

Function Documentation

def CMSSWScenario.load_CMSSW_scenario

(

filename

)

Definition at line 29 of file CMSSWScenario.py.

def load_CMSSW_scenario(filename):
  data = open(filename).read()
  workflow = eval(data)
  cpu_cruncher_algos = []
  cpu_cruncher_algos_inputs = []
  all_outputs = set()
  all_inputs  = set()
  for algo in workflow["process"]["producers"]:
    # in the next two lines replace the slash as that is a reserved character in the data store 
    inputs = [ item["label"].replace("/","_") for item in algo["toGet"] ]
    outputs = [algo["@label"].replace("/","_"),]
    new_algo = CPUCruncher(algo["@label"],
                           avgRuntime=float(algo["eventTimes"][0]),
                           DataInputs = inputs,
                           DataOutputs = outputs
                          )

    cpu_cruncher_algos.append(new_algo)
    all_outputs.update(outputs)
    all_inputs.update(inputs)
    cpu_cruncher_algos_inputs.append(inputs)
  
  #look for the objects that haven't been provided within the job. Assume this needs to come via input
  new_algo = CPUCruncher("input",
                         avgRuntime=1,
                         DataInputs=[],
                         DataOutputs=[item for item in all_inputs.difference(all_outputs)]
                         )
  cpu_cruncher_algos.append(new_algo)
  cpu_cruncher_algos_inputs.append([])

  print [item for item in all_inputs.difference(all_outputs)]
  return cpu_cruncher_algos,cpu_cruncher_algos_inputs
        
# Set output level threshold 2=DEBUG, 3=INFO, 4=WARNING, 5=ERROR, 6=FATAL )

Variable Documentation

tuple CMSSWScenario.app = ApplicationMgr()

Definition at line 79 of file CMSSWScenario.py.

CMSSWScenario.CLONEALGOS = False

Definition at line 15 of file CMSSWScenario.py.

CMSSWScenario.CloneAlgos = CLONEALGOS

Definition at line 24 of file CMSSWScenario.py.

CMSSWScenario.DUMPQUEUES = False

Definition at line 16 of file CMSSWScenario.py.

CMSSWScenario.DumpQueues = DUMPQUEUES

Definition at line 25 of file CMSSWScenario.py.

tuple CMSSWScenario.evtloop = HiveEventLoopMgr()

Definition at line 70 of file CMSSWScenario.py.

tuple CMSSWScenario.ms = MessageSvc()

Definition at line 64 of file CMSSWScenario.py.

int CMSSWScenario.NUMBEROFALGOSINFLIGHT = 1000

Definition at line 13 of file CMSSWScenario.py.

CMSSWScenario.NumberOfAlgosInFlight = NUMBEROFALGOSINFLIGHT

Definition at line 22 of file CMSSWScenario.py.

int CMSSWScenario.NUMBEROFEVENTS = 1

Definition at line 11 of file CMSSWScenario.py.

CMSSWScenario.NumberOfEvents = NUMBEROFEVENTS

Definition at line 20 of file CMSSWScenario.py.

int CMSSWScenario.NUMBEROFEVENTSINFLIGHT = 1

Definition at line 12 of file CMSSWScenario.py.

CMSSWScenario.NumberOfEventsInFlight = NUMBEROFEVENTSINFLIGHT

Definition at line 21 of file CMSSWScenario.py.

int CMSSWScenario.NUMBEROFTHREADS = 1

Definition at line 14 of file CMSSWScenario.py.

CMSSWScenario.NumberOfThreads = NUMBEROFTHREADS

Definition at line 23 of file CMSSWScenario.py.

int CMSSWScenario.VERBOSITY = 3

Definition at line 17 of file CMSSWScenario.py.

CMSSWScenario.Verbosity = VERBOSITY

Definition at line 26 of file CMSSWScenario.py.