7 |
|
def __init__(self, cfg_params, jobs): |
8 |
|
self.cfg_params = cfg_params |
9 |
|
|
10 |
+ |
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 |
|
nj_list = [] |
14 |
< |
|
15 |
< |
nj_list = self.checkAlowedJob(jobs,nj_list) |
14 |
> |
|
15 |
> |
# get updated status from server |
16 |
> |
try: |
17 |
> |
from StatusServer import StatusServer |
18 |
> |
stat = StatusServer(self.cfg_params) |
19 |
> |
stat.resynchClientSide() |
20 |
> |
except: |
21 |
> |
pass |
22 |
> |
|
23 |
> |
nj_list = self.checkAllowedJob(jobs,nj_list) |
24 |
|
|
25 |
|
SubmitterServer.__init__(self, cfg_params, nj_list, 'range') |
26 |
|
|