134 |
|
def listMatch(*args): return apply(_BossSession.BossSession_listMatch,args) |
135 |
|
def schedulerQuery(*args): return apply(_BossSession.BossSession_schedulerQuery,args) |
136 |
|
def selectTasks(*args): return apply(_BossSession.BossSession_selectTasks,args) |
137 |
+ |
def selectTasksByName(*args): return apply(_BossSession.BossSession_selectTasksByName,args) |
138 |
|
def query(*args): return apply(_BossSession.BossSession_query,args) |
139 |
+ |
def getTasksByName(*args): return apply(_BossSession.BossSession_getTasksByName,args) |
140 |
|
def show(*args): return apply(_BossSession.BossSession_show,args) |
141 |
|
def CHTools(*args): return apply(_BossSession.BossSession_CHTools,args) |
142 |
|
def ProgramTypes(*args): return apply(_BossSession.BossSession_ProgramTypes,args) |
153 |
|
after = "", |
154 |
|
before = "", |
155 |
|
timeout = 0, |
156 |
< |
avoidCheck = 0): |
157 |
< |
my = self.queryTasks( filter_opt, taskRange, jobRange, subn, type, user, after, before, int(timeout), avoidCheck ) |
156 |
> |
avoidCheck = 0): |
157 |
> |
if avoidCheck > 0 : |
158 |
> |
self.schedulerQuery ( filter_opt, taskRange, jobRange, subn, type, user, after, before, timeout ) |
159 |
> |
my = self.queryTasks("",taskRange, after, before, user ) |
160 |
|
ciao = {} |
161 |
|
for i in my: |
162 |
< |
ciao[i] = self.makeBossTask(i) |
162 |
> |
ciao[i] = self.makeBossTask(i) |
163 |
|
ciao[i].query(filter_opt, jobRange, subn, type, user, after, before, 0, 1) |
164 |
|
return ciao |
165 |
|
|
166 |
|
|
167 |
+ |
def queryByName( self, taskName ): |
168 |
+ |
my = self.queryTasks(taskName) |
169 |
+ |
ciao = {} |
170 |
+ |
for i in my: |
171 |
+ |
ciao[i] = self.makeBossTask(i) |
172 |
+ |
ciao[i].load(ALL) |
173 |
+ |
return ciao |
174 |
+ |
|
175 |
+ |
|
176 |
|
def __repr__(self): |
177 |
|
return "<C BossSession instance at %s>" % (self.this,) |
178 |
|
|
237 |
|
def reSubmit(*args): return apply(_BossSession.BossTask_reSubmit,args) |
238 |
|
def kill(*args): return apply(_BossSession.BossTask_kill,args) |
239 |
|
def getOutput(*args): return apply(_BossSession.BossTask_getOutput,args) |
240 |
+ |
def loadByName(*args): return apply(_BossSession.BossTask_loadByName,args) |
241 |
|
def load(*args): return apply(_BossSession.BossTask_load,args) |
242 |
|
def query(*args): return apply(_BossSession.BossTask_query,args) |
243 |
|
def query_out(*args): return apply(_BossSession.BossTask_query_out,args) |