Revision: | 1.2 |
Committed: | Sun Oct 26 12:49:15 2008 UTC (16 years, 6 months ago) by spiga |
Content type: | text/x-python |
Branch: | MAIN |
CVS Tags: | CRAB_2_6_0_pre7, CRAB_2_6_0_pre6, CRAB_2_6_0_pre5, CRAB_2_6_0_pre4, CRAB_2_6_0_pre3, 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 |
Changes since 1.1: | +9 -1 lines |
Log Message: | resync client DB before take action |
# | Content |
---|---|
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 | nj_list = [] |
11 | |
12 | # get updated status from server |
13 | try: |
14 | from StatusServer import StatusServer |
15 | stat = StatusServer(self.cfg_params) |
16 | stat.resynchClientSide() |
17 | except: |
18 | pass |
19 | |
20 | nj_list = self.checkAlowedJob(jobs,nj_list) |
21 | |
22 | SubmitterServer.__init__(self, cfg_params, nj_list, 'range') |
23 | |
24 | return |
25 | |
26 |