| Revision: | 1.6 |
| Committed: | Thu Jan 17 16:24:16 2013 UTC (12 years, 3 months ago) by slacapra |
| Content type: | text/x-python |
| Branch: | MAIN |
| CVS Tags: | CRAB_2_9_1, CRAB_2_9_1_pre2, CRAB_2_9_1_pre1, CRAB_2_9_0, CRAB_2_9_0_pre2, CRAB_2_9_0_pre1, CRAB_2_8_8, CRAB_2_8_8_pre1, CRAB_2_8_7_patch3, CRAB_2_8_7_patch2, CRAB_2_8_7_patch1, CRAB_2_8_7, CRAB_2_8_7_pre2, CRAB_2_8_7_pre1, CRAB_2_8_6, CRAB_2_8_6_pre1, CRAB_2_8_5_patch3, CRAB_2_8_5_patch2, CRAB_2_8_5_patch1, CRAB_2_8_5, CRAB_2_8_5_pre5, CRAB_2_8_5_pre4, CRAB_2_8_5_pre3, HEAD |
| Changes since 1.5: | +4 -1 lines |
| Log Message: | implement -resubmit bad as per task #39244 |
| # | User | Rev | Content |
|---|---|---|---|
| 1 | spiga | 1.1 | from SubmitterServer import SubmitterServer |
| 2 | from Resubmitter import Resubmitter | ||
| 3 | import common | ||
| 4 | from crab_util import * | ||
| 5 | |||
| 6 | class ResubmitterServer(SubmitterServer, Resubmitter): | ||
| 7 | def __init__(self, cfg_params, jobs): | ||
| 8 | self.cfg_params = cfg_params | ||
| 9 | |||
| 10 | spiga | 1.4 | self.copy_data = int(cfg_params.get('USER.copy_data',0)) |
| 11 | self.check_RemoteDir = int(cfg_params.get('USER.check_user_remote_dir',0)) | ||
| 12 | |||
| 13 | spiga | 1.1 | nj_list = [] |
| 14 | spiga | 1.2 | |
| 15 | # get updated status from server | ||
| 16 | try: | ||
| 17 | from StatusServer import StatusServer | ||
| 18 | stat = StatusServer(self.cfg_params) | ||
| 19 | mcinquil | 1.5 | warning_msg = stat.resynchClientSide() |
| 20 | if warning_msg is not None: | ||
| 21 | common.logger.info(warning_msg) | ||
| 22 | spiga | 1.2 | except: |
| 23 | pass | ||
| 24 | |||
| 25 | slacapra | 1.6 | if (jobs=='bad'): |
| 26 | nj_list = self.checkBadJob(nj_list) | ||
| 27 | else: | ||
| 28 | nj_list = self.checkAllowedJob(jobs,nj_list) | ||
| 29 | spiga | 1.1 | |
| 30 | SubmitterServer.__init__(self, cfg_params, nj_list, 'range') | ||
| 31 | |||
| 32 | return | ||
| 33 | |||
| 34 |