AthenaScenario Namespace Reference

Functions
def	load_athena_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	whiteboard = HiveWhiteBoard("EventDataSvc", EventSlots = NumberOfEventsInFlight)
tuple	evtloop = HiveEventLoopMgr()
tuple	app = ApplicationMgr()

Function Documentation

def AthenaScenario.load_athena_scenario

(

filename

)

Definition at line 29 of file AthenaScenario.py.

def load_athena_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["algorithms"]:
    # Correct in presence of list wi
    for starputs in ("inputs","outputs"):
      algo[starputs] = [item.replace("/","_") for item in algo[starputs]]
      if algo[starputs] == ['']: algo[starputs] = []
      if algo[starputs] == ['dummy']: algo[starputs] = []
    cleaned_inputs = [input for input in algo["inputs"] if (input not in algo["outputs"] ) ]

    # fix double declaration of outputs (nokey)
    cleaned_outputs = [output for output in algo["outputs"] if (output not in all_outputs)]
    new_algo = CPUCruncher(algo["name"],
                           avgRuntime=float(algo["runtimes"][0]/1000000.),
                           DataInputs = cleaned_inputs,
                           DataOutputs = cleaned_outputs
                           )
    cpu_cruncher_algos.append(new_algo)
    all_outputs.update(algo["outputs"])
    all_inputs.update(algo["inputs"])
    cpu_cruncher_algos_inputs.append(algo["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)]

  print len(all_outputs)
  print len(cpu_cruncher_algos)
  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 AthenaScenario.app = ApplicationMgr()

Definition at line 89 of file AthenaScenario.py.

AthenaScenario.CLONEALGOS = False

Definition at line 15 of file AthenaScenario.py.

AthenaScenario.CloneAlgos = CLONEALGOS

Definition at line 24 of file AthenaScenario.py.

AthenaScenario.DUMPQUEUES = False

Definition at line 16 of file AthenaScenario.py.

AthenaScenario.DumpQueues = DUMPQUEUES

Definition at line 25 of file AthenaScenario.py.

tuple AthenaScenario.evtloop = HiveEventLoopMgr()

Definition at line 80 of file AthenaScenario.py.

tuple AthenaScenario.ms = MessageSvc()

Definition at line 72 of file AthenaScenario.py.

int AthenaScenario.NUMBEROFALGOSINFLIGHT = 1000

Definition at line 13 of file AthenaScenario.py.

AthenaScenario.NumberOfAlgosInFlight = NUMBEROFALGOSINFLIGHT

Definition at line 22 of file AthenaScenario.py.

int AthenaScenario.NUMBEROFEVENTS = 1

Definition at line 11 of file AthenaScenario.py.

AthenaScenario.NumberOfEvents = NUMBEROFEVENTS

Definition at line 20 of file AthenaScenario.py.

int AthenaScenario.NUMBEROFEVENTSINFLIGHT = 1

Definition at line 12 of file AthenaScenario.py.

AthenaScenario.NumberOfEventsInFlight = NUMBEROFEVENTSINFLIGHT

Definition at line 21 of file AthenaScenario.py.

int AthenaScenario.NUMBEROFTHREADS = 1

Definition at line 14 of file AthenaScenario.py.

AthenaScenario.NumberOfThreads = NUMBEROFTHREADS

Definition at line 23 of file AthenaScenario.py.

int AthenaScenario.VERBOSITY = 3

Definition at line 17 of file AthenaScenario.py.

AthenaScenario.Verbosity = VERBOSITY

Definition at line 26 of file AthenaScenario.py.

tuple AthenaScenario.whiteboard = HiveWhiteBoard("EventDataSvc", EventSlots = NumberOfEventsInFlight)

Definition at line 77 of file AthenaScenario.py.