ATLAS Offline Software
Loading...
Searching...
No Matches
python.AlgScheduler Namespace Reference

Classes

class  AlgScheduler

Functions

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

Variables

 AlgScheduler = AlgScheduler()
 SchedulerSvc

Function Documentation

◆ CheckDependencies()

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()

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()

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()

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()

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()

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()

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()

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()

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()

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()

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()

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

python.AlgScheduler.AlgScheduler = AlgScheduler()

Definition at line 167 of file AlgScheduler.py.

◆ SchedulerSvc

python.AlgScheduler.SchedulerSvc

Definition at line 78 of file AlgScheduler.py.