| 16 |
|
task = common._db.getTask(self.range) |
| 17 |
|
toBeKilled = [] |
| 18 |
|
for job in task.jobs: |
| 19 |
< |
# if id not in common._db.nJobs("list"): |
| 20 |
< |
# common.logger.message("Warning: job # "+str(id)+" doesn't exists! Not possible to kill it.") |
| 21 |
< |
# else: |
| 22 |
< |
if ( job.runningJob['status'] in ['SS','R','S']): |
| 19 |
> |
if ( job.runningJob['status'] in ['SU','SS','R','S','SR','SW']): |
| 20 |
|
toBeKilled.append(job['jobId']) |
| 21 |
|
else: |
| 22 |
< |
common.logger.message("Not possible to kill Job #"+str(job['jobId'])+" : Status is "+str(job.runningJob['schedulerStatus'])) |
| 22 |
> |
common.logger.message("Not possible to kill Job #"+str(job['jobId'])+" : Status is "+str(job.runningJob['statusScheduler'])) |
| 23 |
|
pass |
| 24 |
|
|
| 25 |
|
if len(toBeKilled)>0: |
