13 |
|
self.cfg_params = cfg_params |
14 |
|
self.nj_list = nj_list |
15 |
|
if (cfg_params.get('USER.copy_data',0) == '0') : |
16 |
< |
raise CrabException("Cannot copy output locally if it has not \ |
17 |
< |
been stored to SE via USER.copy_data=1") |
16 |
> |
msg = 'Cannot copy output locally if it has not \n' |
17 |
> |
msg += '\tbeen stored to SE via USER.copy_data=1' |
18 |
> |
raise CrabException(msg) |
19 |
|
|
20 |
|
# update local DB |
21 |
|
if StatusObj:# this is to avoid a really strange segv |
123 |
|
id_job = job['jobId'] |
124 |
|
if ( job.runningJob['status'] in ['E','UE'] and job.runningJob[ 'wrapperReturnCode'] == 0): |
125 |
|
for of in output_file: |
126 |
< |
a,b=of.split('.') |
126 |
> |
b=of.split('.')[-1:] |
127 |
> |
b = b[0] |
128 |
> |
a=of.split('.%s'%b)[0] |
129 |
|
InfileList += '%s_%s.%s%s'%(a,id_job,b,',') |
130 |
|
elif ( job.runningJob['status'] in ['E','UE'] and job.runningJob['wrapperReturnCode'] != 0): |
131 |
|
common.logger.message("Not possible copy outputs of Job # %s : Wrapper Exit Code is %s" \ |
136 |
|
pass |
137 |
|
|
138 |
|
if (InfileList == '') : |
139 |
< |
raise CrabException("No files to be copyed") |
139 |
> |
raise CrabException("No files to copy") |
140 |
|
|
141 |
|
return InfileList[:-1] |
142 |
|
|