ATLAS Offline Software
Classes | Functions | Variables
python.AlgScheduler Namespace Reference

Classes

class  AlgScheduler
 

Functions

def SetScheduler (self, theSched)
 exchange the current scheduler for another one More...
 
def OutputLevel (self, level)
 change the output level More...
 
def CheckDependencies (self, check=True)
 control checking of data deps at beginning of job for unmet input deps More...
 
def ShowControlFlow (self, show=True)
 control printout of control flow at beginning of job More...
 
def ShowDataFlow (self, show=True)
 control printout of data flow at beginning of job More...
 
def ShowDataDependencies (self, show=True)
 control printout of data dependencies at beginning of job More...
 
def setDataLoaderAlg (self, dataLoadAlg)
 set the DataLoader Algorithm to handle unmet input data deps More...
 
def EnableConditions (self, enable=True)
 enable condition handling More...
 
def EnableVerboseViews (self, enable=True)
 enable verbose view state logging More...
 
def setAlgRanking (self, rule="PCE")
 set algorithm ranking rule More...
 
def setThreadPoolSize (self, tps)
 explicitly set the thread pool size More...
 
def getScheduler (self)
 get the currently configured scheduler More...
 

Variables

 AlgScheduler = AlgScheduler()
 
 SchedulerSvc
 

Function Documentation

◆ CheckDependencies()

def python.AlgScheduler.CheckDependencies (   self,
  check = True 
)

control checking of data deps at beginning of job for unmet input deps

Definition at line 89 of file AlgScheduler.py.

89  def CheckDependencies(self,check=True):
90  if ( 'CheckDependencies' in self.SchedulerSvc.properties() ):
91  self.SchedulerSvc.CheckDependencies = check
92  else :
93  self.log.warning( self.SchedulerSvc.getFullName() + " has no property \"CheckDependencies\"")
94 
95 #

◆ EnableConditions()

def python.AlgScheduler.EnableConditions (   self,
  enable = True 
)

enable condition handling

Definition at line 129 of file AlgScheduler.py.

129  def EnableConditions(self,enable=True):
130  if ( 'EnableConditions' in self.SchedulerSvc.properties() ):
131  self.SchedulerSvc.EnableConditions = enable
132  else :
133  self.log.warning(self.SchedulerSvc.getFullName() + " has no property \"EnableConditions\"")
134 
135 #

◆ EnableVerboseViews()

def python.AlgScheduler.EnableVerboseViews (   self,
  enable = True 
)

enable verbose view state logging

Definition at line 137 of file AlgScheduler.py.

137  def EnableVerboseViews(self,enable=True):
138  if ( 'VerboseSubSlots' in self.SchedulerSvc.properties() ):
139  self.SchedulerSvc.VerboseSubSlots = enable
140  else :
141  self.log.warning(self.SchedulerSvc.getFullName() + " has no property \"VerboseSubSlots\"")
142 
143 #

◆ getScheduler()

def python.AlgScheduler.getScheduler (   self)

get the currently configured scheduler

Get the Scheduler

Definition at line 162 of file AlgScheduler.py.

162  def getScheduler(self):
163  """Get the Scheduler"""
164  return self.SchedulerSvc
165 

◆ OutputLevel()

def python.AlgScheduler.OutputLevel (   self,
  level 
)

change the output level

Definition at line 83 of file AlgScheduler.py.

83  def OutputLevel(self,level) :
84  self.SchedulerSvc.OutputLevel = level
85  self.PrecedenceSvc.OutputLevel = level
86 
87 #

◆ setAlgRanking()

def python.AlgScheduler.setAlgRanking (   self,
  rule = "PCE" 
)

set algorithm ranking rule

Definition at line 145 of file AlgScheduler.py.

145  def setAlgRanking(self,rule="PCE"):
146  if ( 'Optimizer' in self.SchedulerSvc.properties() ):
147  self.SchedulerSvc.Optimizer = rule
148  else :
149  self.log.warning(self.SchedulerSvc.getFullName() + " has no property \"Optimizer\"")
150  if ( 'TaskPriorityRule' in self.PrecedenceSvc.properties() ):
151  self.PrecedenceSvc.TaskPriorityRule = rule
152  else :
153  self.log.warning(self.PrecedenceSvc.getFullName() + " has no property \"TaskPriorityRule\"")
154 
155 #

◆ setDataLoaderAlg()

def python.AlgScheduler.setDataLoaderAlg (   self,
  dataLoadAlg 
)

set the DataLoader Algorithm to handle unmet input data deps

Definition at line 121 of file AlgScheduler.py.

121  def setDataLoaderAlg(self,dataLoadAlg):
122  if ( 'DataLoaderAlg' in self.SchedulerSvc.properties() ):
123  self.SchedulerSvc.DataLoaderAlg = dataLoadAlg
124  else :
125  self.log.warning(self.SchedulerSvc.getFullName() + " has no property \"DataLoaderAlg\"")
126 
127 #

◆ SetScheduler()

def python.AlgScheduler.SetScheduler (   self,
  theSched 
)

exchange the current scheduler for another one

setup a different Scheduler

Definition at line 70 of file AlgScheduler.py.

70  def SetScheduler(self,theSched):
71  """setup a different Scheduler"""
72 
73  if (self.SchedulerSvc.getFullName() != theSched.getFullName()) :
74  self.log.info("replacing " + self.SchedulerSvc.getFullName()
75  + " with " + theSched.getFullName())
76  from AthenaCommon.AppMgr import ServiceMgr as svcMgr
77  svcMgr.remove(self.SchedulerSvc)
78  svcMgr += theSched
79  self.SchedulerSvc = theSched
80 
81 #

◆ setThreadPoolSize()

def python.AlgScheduler.setThreadPoolSize (   self,
  tps 
)

explicitly set the thread pool size

Definition at line 157 of file AlgScheduler.py.

157  def setThreadPoolSize(self,tps) :
158  self.SchedulerSvc.ThreadPoolSize = tps
159 
160 #

◆ ShowControlFlow()

def python.AlgScheduler.ShowControlFlow (   self,
  show = True 
)

control printout of control flow at beginning of job

Definition at line 97 of file AlgScheduler.py.

97  def ShowControlFlow(self,show=True):
98  if ( 'ShowControlFlow' in self.SchedulerSvc.properties() ):
99  self.SchedulerSvc.ShowControlFlow = show
100  else :
101  self.log.warning(self.SchedulerSvc.getFullName() + " has no property \"ShowControlFlow\"")
102 
103 #

◆ ShowDataDependencies()

def python.AlgScheduler.ShowDataDependencies (   self,
  show = True 
)

control printout of data dependencies at beginning of job

Definition at line 113 of file AlgScheduler.py.

113  def ShowDataDependencies(self,show=True):
114  if ( 'ShowDataDependencies' in self.SchedulerSvc.properties() ):
115  self.SchedulerSvc.ShowDataDependencies = show
116  else :
117  self.log.warning(self.SchedulerSvc.getFullName() + " has no property \"ShowDataDependencies\"")
118 
119 #

◆ ShowDataFlow()

def python.AlgScheduler.ShowDataFlow (   self,
  show = True 
)

control printout of data flow at beginning of job

Definition at line 105 of file AlgScheduler.py.

105  def ShowDataFlow(self,show=True):
106  if ( 'ShowDataFlow' in self.SchedulerSvc.properties() ):
107  self.SchedulerSvc.ShowDataFlow = show
108  else :
109  self.log.warning(self.SchedulerSvc.getFullName() + " has no property \"ShowDataFlow\"")
110 
111 #

Variable Documentation

◆ AlgScheduler

Definition at line 166 of file AlgScheduler.py.

◆ SchedulerSvc

python.AlgScheduler.SchedulerSvc

Definition at line 79 of file AlgScheduler.py.

grepfile.info
info
Definition: grepfile.py:38
python.AlgScheduler.EnableVerboseViews
def EnableVerboseViews(self, enable=True)
enable verbose view state logging
Definition: AlgScheduler.py:137
python.AlgScheduler.setDataLoaderAlg
def setDataLoaderAlg(self, dataLoadAlg)
set the DataLoader Algorithm to handle unmet input data deps
Definition: AlgScheduler.py:121
python.AlgScheduler.EnableConditions
def EnableConditions(self, enable=True)
enable condition handling
Definition: AlgScheduler.py:129
python.AlgScheduler.setThreadPoolSize
def setThreadPoolSize(self, tps)
explicitly set the thread pool size
Definition: AlgScheduler.py:157
python.AlgScheduler.SetScheduler
def SetScheduler(self, theSched)
exchange the current scheduler for another one
Definition: AlgScheduler.py:70
python.AlgScheduler.OutputLevel
def OutputLevel(self, level)
change the output level
Definition: AlgScheduler.py:83
python.AlgScheduler.ShowDataFlow
def ShowDataFlow(self, show=True)
control printout of data flow at beginning of job
Definition: AlgScheduler.py:105
python.JsonUtils.properties
properties
Definition: JsonUtils.py:96
python.AlgScheduler.setAlgRanking
def setAlgRanking(self, rule="PCE")
set algorithm ranking rule
Definition: AlgScheduler.py:145
python.AlgScheduler.ShowControlFlow
def ShowControlFlow(self, show=True)
control printout of control flow at beginning of job
Definition: AlgScheduler.py:97
python.AlgScheduler.ShowDataDependencies
def ShowDataDependencies(self, show=True)
control printout of data dependencies at beginning of job
Definition: AlgScheduler.py:113
python.AnaAlgSequence.getFullName
def getFullName(comp)
Definition: AnaAlgSequence.py:12
python.AlgScheduler.getScheduler
def getScheduler(self)
get the currently configured scheduler
Definition: AlgScheduler.py:162
python.AlgScheduler.CheckDependencies
def CheckDependencies(self, check=True)
control checking of data deps at beginning of job for unmet input deps
Definition: AlgScheduler.py:89