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 90 of file AlgScheduler.py.

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

◆ EnableConditions()

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

enable condition handling

Definition at line 130 of file AlgScheduler.py.

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

◆ EnableVerboseViews()

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

enable verbose view state logging

Definition at line 138 of file AlgScheduler.py.

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

◆ getScheduler()

def python.AlgScheduler.getScheduler (   self)

get the currently configured scheduler

Get the Scheduler

Definition at line 163 of file AlgScheduler.py.

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

◆ OutputLevel()

def python.AlgScheduler.OutputLevel (   self,
  level 
)

change the output level

Definition at line 84 of file AlgScheduler.py.

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

◆ setAlgRanking()

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

set algorithm ranking rule

Definition at line 146 of file AlgScheduler.py.

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

◆ setDataLoaderAlg()

def python.AlgScheduler.setDataLoaderAlg (   self,
  dataLoadAlg 
)

set the DataLoader Algorithm to handle unmet input data deps

Definition at line 122 of file AlgScheduler.py.

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

◆ SetScheduler()

def python.AlgScheduler.SetScheduler (   self,
  theSched 
)

exchange the current scheduler for another one

setup a different Scheduler

Definition at line 71 of file AlgScheduler.py.

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

◆ setThreadPoolSize()

def python.AlgScheduler.setThreadPoolSize (   self,
  tps 
)

explicitly set the thread pool size

Definition at line 158 of file AlgScheduler.py.

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

◆ ShowControlFlow()

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

control printout of control flow at beginning of job

Definition at line 98 of file AlgScheduler.py.

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

◆ ShowDataDependencies()

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

control printout of data dependencies at beginning of job

Definition at line 114 of file AlgScheduler.py.

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

◆ ShowDataFlow()

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

control printout of data flow at beginning of job

Definition at line 106 of file AlgScheduler.py.

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

Variable Documentation

◆ AlgScheduler

Definition at line 167 of file AlgScheduler.py.

◆ SchedulerSvc

python.AlgScheduler.SchedulerSvc

Definition at line 80 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:138
python.TestDriveDummies.properties
dictionary properties
Definition: TestDriveDummies.py:14
python.AlgScheduler.setDataLoaderAlg
def setDataLoaderAlg(self, dataLoadAlg)
set the DataLoader Algorithm to handle unmet input data deps
Definition: AlgScheduler.py:122
python.AlgScheduler.EnableConditions
def EnableConditions(self, enable=True)
enable condition handling
Definition: AlgScheduler.py:130
python.AlgScheduler.setThreadPoolSize
def setThreadPoolSize(self, tps)
explicitly set the thread pool size
Definition: AlgScheduler.py:158
python.AlgScheduler.SetScheduler
def SetScheduler(self, theSched)
exchange the current scheduler for another one
Definition: AlgScheduler.py:71
python.AlgScheduler.OutputLevel
def OutputLevel(self, level)
change the output level
Definition: AlgScheduler.py:84
python.AlgScheduler.ShowDataFlow
def ShowDataFlow(self, show=True)
control printout of data flow at beginning of job
Definition: AlgScheduler.py:106
python.AlgScheduler.setAlgRanking
def setAlgRanking(self, rule="PCE")
set algorithm ranking rule
Definition: AlgScheduler.py:146
python.AlgScheduler.ShowControlFlow
def ShowControlFlow(self, show=True)
control printout of control flow at beginning of job
Definition: AlgScheduler.py:98
python.AlgScheduler.ShowDataDependencies
def ShowDataDependencies(self, show=True)
control printout of data dependencies at beginning of job
Definition: AlgScheduler.py:114
python.AlgScheduler.getScheduler
def getScheduler(self)
get the currently configured scheduler
Definition: AlgScheduler.py:163
python.AlgScheduler.CheckDependencies
def CheckDependencies(self, check=True)
control checking of data deps at beginning of job for unmet input deps
Definition: AlgScheduler.py:90