| Revision: | 1.13 |
| Committed: | Thu Sep 4 08:00:04 2008 UTC (16 years, 7 months ago) by spiga |
| Content type: | text/x-python |
| Branch: | MAIN |
| CVS Tags: | CRAB_2_6_0_pre2, CRAB_2_6_0_pre1, CRAB_2_5_1, CRAB_2_5_1_pre4, CRAB_2_5_1_pre3, CRAB_2_5_1_pre2, CRAB_2_5_1_pre1, CRAB_2_5_0, CRAB_2_5_0_pre7, CRAB_2_5_0_pre6, CRAB_2_5_0_pre5, CRAB_2_5_0_pre4, CRAB_2_5_0_pre3, CRAB_2_5_0_pre2, CRAB_2_5_0_pre1, CRAB_2_4_4, CRAB_2_4_4_pre6, CRAB_2_4_4_pre5, CRAB_2_4_4_pre4, CRAB_2_4_4_pre3, CRAB_2_4_4_pre2, CRAB_2_4_4_pre1, CRAB_2_4_3, CRAB_2_4_3_pre8, CRAB_2_4_3_pre7, CRAB_2_4_3_pre6, CRAB_2_4_3_pre5, CRAB_2_4_3_pre3, CRAB_2_4_3_pre2, CRAB_2_4_3_pre1, CRAB_2_4_2, CRAB_2_4_2_pre3, CRAB_2_4_2_pre2, CRAB_2_4_2_pre1, CRAB_2_4_1, CRAB_2_4_1_pre4, CRAB_2_4_1_pre3, CRAB_2_4_1_pre2, CRAB_2_4_1_pre1, CRAB_2_4_0_Tutorial, CRAB_2_4_0_Tutorial_pre1, CRAB_2_4_0, CRAB_2_4_0_pre9, CRAB_2_4_0_pre8, CRAB_2_4_0_pre7, CRAB_2_4_0_pre6, CRAB_2_4_0_pre5, CRAB_2_4_0_pre4, CRAB_2_4_0_pre3, CRAB_2_4_0_pre2, CRAB_2_4_0_pre1, CRAB_DLS_PHED1, CRAB_DLS_PHED, CRAB_2_3_2_Fnal, CRAB_2_3_2 |
| Changes since 1.12: | +1 -1 lines |
| Log Message: | update PCommon tag |
| # | User | Rev | Content |
|---|---|---|---|
| 1 | slacapra | 1.1 | import os, common, string |
| 2 | from Actor import * | ||
| 3 | from crab_util import * | ||
| 4 | |||
| 5 | class Killer(Actor): | ||
| 6 | def __init__(self, cfg_params, range): | ||
| 7 | self.cfg_params = cfg_params | ||
| 8 | self.range = range | ||
| 9 | return | ||
| 10 | |||
| 11 | def run(self): | ||
| 12 | """ | ||
| 13 | The main method of the class: kill a complete task | ||
| 14 | """ | ||
| 15 | common.logger.debug(5, "Killer::run() called") | ||
| 16 | spiga | 1.7 | task = common._db.getTask(self.range) |
| 17 | slacapra | 1.1 | toBeKilled = [] |
| 18 | spiga | 1.7 | for job in task.jobs: |
| 19 | spiga | 1.13 | if ( job.runningJob['status'] in ['SU','SS','R','S','SR','SW']): |
| 20 | spiga | 1.7 | toBeKilled.append(job['jobId']) |
| 21 | else: | ||
| 22 | spiga | 1.8 | common.logger.message("Not possible to kill Job #"+str(job['jobId'])+" : Status is "+str(job.runningJob['statusScheduler'])) |
| 23 | spiga | 1.7 | pass |
| 24 | slacapra | 1.1 | |
| 25 | spiga | 1.4 | if len(toBeKilled)>0: |
| 26 | common.scheduler.cancel(toBeKilled) | ||
| 27 | common.logger.message("Jobs killed "+str(toBeKilled)) |