180 |
|
Jobs = task.getJobs() |
181 |
|
print "--------------------------" |
182 |
|
for Job in Jobs: |
183 |
< |
print "Id: ",Job['id'] |
183 |
> |
print "Id: ",Job['jobId'] |
184 |
|
print "Dest: ", Job['dlsDestination'] |
185 |
|
print "Output: ", Job['outputFiles'] |
186 |
|
print "Args: ",Job['arguments'] |
206 |
|
for job in task.jobs: |
207 |
|
toPrint='' |
208 |
|
common.bossSession.getRunningInstance(job) |
209 |
< |
toPrint = "%-5s %-50s " % (job['id'],job.runningJob['schedulerId']) |
209 |
> |
toPrint = "%-5s %-50s " % (job['jobId'],job.runningJob['schedulerId']) |
210 |
|
lines.append(toPrint) |
211 |
|
header+= "%-5s %-50s " % ('Job:','ID' ) |
212 |
|
displayReport(self,header,lines) |
306 |
|
task = self.getTask(nj) |
307 |
|
|
308 |
|
for job in task.jobs: |
309 |
< |
if job.runningJob is not None : |
310 |
< |
job.runningJob["closed"] = "Y" |
311 |
< |
|
312 |
< |
common.bossSession.updateDB(task) |
313 |
< |
|
314 |
< |
for job in task.jobs: |
315 |
< |
job.runningJob = None |
316 |
< |
common.bossSession.getRunningInstance(job) |
309 |
> |
common.bossSession.getNewRunningInstance(job) |
310 |
> |
job.runningJob['status'] = 'C' |
311 |
> |
job.runningJob['statusScheduler'] = 'Created' |
312 |
> |
common.bossSession.updateDB(task) |
313 |
|
return |
314 |
|
|
315 |
|
def deserXmlStatus(self, reportList): |