| 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 |
|
# get updated status from server |
| 16 |
|
try: |
| 17 |
|
from StatusServer import StatusServer |
| 18 |
|
stat = StatusServer(self.cfg_params) |
| 19 |
< |
stat.resynchClientSide() |
| 19 |
> |
warning_msg = stat.resynchClientSide() |
| 20 |
> |
if warning_msg is not None: |
| 21 |
> |
common.logger.info(warning_msg) |
| 22 |
|
except: |
| 23 |
|
pass |
| 24 |
|
|
| 25 |
< |
nj_list = self.checkAllowedJob(jobs,nj_list) |
| 25 |
> |
if (jobs=='bad'): |
| 26 |
> |
nj_list = self.checkBadJob(nj_list) |
| 27 |
> |
else: |
| 28 |
> |
nj_list = self.checkAllowedJob(jobs,nj_list) |
| 29 |
|
|
| 30 |
|
SubmitterServer.__init__(self, cfg_params, nj_list, 'range') |
| 31 |
|
|
