|
ATLAS Offline Software
|
|
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...
|
|
◆ 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.
91 if (
'CheckDependencies' in self.SchedulerSvc.
properties() ):
92 self.SchedulerSvc.CheckDependencies = check
94 self.log.warning( self.SchedulerSvc.getFullName() +
" has no property \"CheckDependencies\"")
◆ EnableConditions()
def python.AlgScheduler.EnableConditions |
( |
|
self, |
|
|
|
enable = True |
|
) |
| |
enable condition handling
Definition at line 130 of file AlgScheduler.py.
131 if (
'EnableConditions' in self.SchedulerSvc.
properties() ):
132 self.SchedulerSvc.EnableConditions = enable
134 self.log.warning(self.SchedulerSvc.getFullName() +
" has no property \"EnableConditions\"")
◆ EnableVerboseViews()
def python.AlgScheduler.EnableVerboseViews |
( |
|
self, |
|
|
|
enable = True |
|
) |
| |
enable verbose view state logging
Definition at line 138 of file AlgScheduler.py.
139 if (
'VerboseSubSlots' in self.SchedulerSvc.
properties() ):
140 self.SchedulerSvc.VerboseSubSlots = enable
142 self.log.warning(self.SchedulerSvc.getFullName() +
" has no property \"VerboseSubSlots\"")
◆ getScheduler()
def python.AlgScheduler.getScheduler |
( |
|
self | ) |
|
get the currently configured scheduler
Get the Scheduler
Definition at line 163 of file AlgScheduler.py.
164 """Get the Scheduler"""
165 return self.SchedulerSvc
◆ OutputLevel()
def python.AlgScheduler.OutputLevel |
( |
|
self, |
|
|
|
level |
|
) |
| |
change the output level
Definition at line 84 of file AlgScheduler.py.
85 self.SchedulerSvc.OutputLevel = level
86 self.PrecedenceSvc.OutputLevel = level
◆ setAlgRanking()
def python.AlgScheduler.setAlgRanking |
( |
|
self, |
|
|
|
rule = "PCE" |
|
) |
| |
set algorithm ranking rule
Definition at line 146 of file AlgScheduler.py.
147 if (
'Optimizer' in self.SchedulerSvc.
properties() ):
148 self.SchedulerSvc.Optimizer = rule
150 self.log.warning(self.SchedulerSvc.getFullName() +
" has no property \"Optimizer\"")
151 if (
'TaskPriorityRule' in self.PrecedenceSvc.
properties() ):
152 self.PrecedenceSvc.TaskPriorityRule = rule
154 self.log.warning(self.PrecedenceSvc.getFullName() +
" has no property \"TaskPriorityRule\"")
◆ 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.
123 if (
'DataLoaderAlg' in self.SchedulerSvc.
properties() ):
124 self.SchedulerSvc.DataLoaderAlg = dataLoadAlg
126 self.log.warning(self.SchedulerSvc.getFullName() +
" has no property \"DataLoaderAlg\"")
◆ 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.
72 """setup a different Scheduler"""
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)
80 self.SchedulerSvc = theSched
◆ setThreadPoolSize()
def python.AlgScheduler.setThreadPoolSize |
( |
|
self, |
|
|
|
tps |
|
) |
| |
explicitly set the thread pool size
Definition at line 158 of file AlgScheduler.py.
159 self.SchedulerSvc.ThreadPoolSize = tps
◆ 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.
99 if (
'ShowControlFlow' in self.SchedulerSvc.
properties() ):
100 self.SchedulerSvc.ShowControlFlow = show
102 self.log.warning(self.SchedulerSvc.getFullName() +
" has no property \"ShowControlFlow\"")
◆ 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.
115 if (
'ShowDataDependencies' in self.SchedulerSvc.
properties() ):
116 self.SchedulerSvc.ShowDataDependencies = show
118 self.log.warning(self.SchedulerSvc.getFullName() +
" has no property \"ShowDataDependencies\"")
◆ 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.
107 if (
'ShowDataFlow' in self.SchedulerSvc.
properties() ):
108 self.SchedulerSvc.ShowDataFlow = show
110 self.log.warning(self.SchedulerSvc.getFullName() +
" has no property \"ShowDataFlow\"")
◆ AlgScheduler
◆ SchedulerSvc
python.AlgScheduler.SchedulerSvc |
def EnableVerboseViews(self, enable=True)
enable verbose view state logging
def setDataLoaderAlg(self, dataLoadAlg)
set the DataLoader Algorithm to handle unmet input data deps
def EnableConditions(self, enable=True)
enable condition handling
def setThreadPoolSize(self, tps)
explicitly set the thread pool size
def SetScheduler(self, theSched)
exchange the current scheduler for another one
def OutputLevel(self, level)
change the output level
def ShowDataFlow(self, show=True)
control printout of data flow at beginning of job
def setAlgRanking(self, rule="PCE")
set algorithm ranking rule
def ShowControlFlow(self, show=True)
control printout of control flow at beginning of job
def ShowDataDependencies(self, show=True)
control printout of data dependencies at beginning of job
def getScheduler(self)
get the currently configured scheduler
def CheckDependencies(self, check=True)
control checking of data deps at beginning of job for unmet input deps