|
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 89 of file AlgScheduler.py.
90 if (
'CheckDependencies' in self.SchedulerSvc.
properties() ):
91 self.SchedulerSvc.CheckDependencies = check
93 self.log.warning( self.SchedulerSvc.getFullName() +
" has no property \"CheckDependencies\"")
◆ EnableConditions()
def python.AlgScheduler.EnableConditions |
( |
|
self, |
|
|
|
enable = True |
|
) |
| |
enable condition handling
Definition at line 129 of file AlgScheduler.py.
130 if (
'EnableConditions' in self.SchedulerSvc.
properties() ):
131 self.SchedulerSvc.EnableConditions = enable
133 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 137 of file AlgScheduler.py.
138 if (
'VerboseSubSlots' in self.SchedulerSvc.
properties() ):
139 self.SchedulerSvc.VerboseSubSlots = enable
141 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 162 of file AlgScheduler.py.
163 """Get the Scheduler"""
164 return self.SchedulerSvc
◆ OutputLevel()
def python.AlgScheduler.OutputLevel |
( |
|
self, |
|
|
|
level |
|
) |
| |
change the output level
Definition at line 83 of file AlgScheduler.py.
84 self.SchedulerSvc.OutputLevel = level
85 self.PrecedenceSvc.OutputLevel = level
◆ setAlgRanking()
def python.AlgScheduler.setAlgRanking |
( |
|
self, |
|
|
|
rule = "PCE" |
|
) |
| |
set algorithm ranking rule
Definition at line 145 of file AlgScheduler.py.
146 if (
'Optimizer' in self.SchedulerSvc.
properties() ):
147 self.SchedulerSvc.Optimizer = rule
149 self.log.warning(self.SchedulerSvc.getFullName() +
" has no property \"Optimizer\"")
150 if (
'TaskPriorityRule' in self.PrecedenceSvc.
properties() ):
151 self.PrecedenceSvc.TaskPriorityRule = rule
153 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 121 of file AlgScheduler.py.
122 if (
'DataLoaderAlg' in self.SchedulerSvc.
properties() ):
123 self.SchedulerSvc.DataLoaderAlg = dataLoadAlg
125 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 70 of file AlgScheduler.py.
71 """setup a different Scheduler"""
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)
79 self.SchedulerSvc = theSched
◆ setThreadPoolSize()
def python.AlgScheduler.setThreadPoolSize |
( |
|
self, |
|
|
|
tps |
|
) |
| |
explicitly set the thread pool size
Definition at line 157 of file AlgScheduler.py.
158 self.SchedulerSvc.ThreadPoolSize = tps
◆ 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.
98 if (
'ShowControlFlow' in self.SchedulerSvc.
properties() ):
99 self.SchedulerSvc.ShowControlFlow = show
101 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 113 of file AlgScheduler.py.
114 if (
'ShowDataDependencies' in self.SchedulerSvc.
properties() ):
115 self.SchedulerSvc.ShowDataDependencies = show
117 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 105 of file AlgScheduler.py.
106 if (
'ShowDataFlow' in self.SchedulerSvc.
properties() ):
107 self.SchedulerSvc.ShowDataFlow = show
109 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