| 5 |
|
from WorkSpace import * |
| 6 |
|
from urlparse import urlparse |
| 7 |
|
from LFNBaseName import * |
| 8 |
+ |
from crab_util import getUserName |
| 9 |
|
|
| 10 |
|
class PhEDExDatasvcInfo: |
| 11 |
|
def __init__( self , cfg_params=None, config=None ): |
| 14 |
|
self.datasvc_url="https://cmsweb.cern.ch/phedex/datasvc/xml/prod" |
| 15 |
|
|
| 16 |
|
self.FacOps_savannah = 'https://savannah.cern.ch/support/?func=additem&group=cmscompinfrasup' |
| 17 |
< |
stage_out_faq='https://twiki.cern.ch/twiki/bin/view/CMS/SWGuideCrabHowTo#Stageout_and_publication' |
| 17 |
> |
self.stage_out_faq='https://twiki.cern.ch/twiki/bin/view/CMS/SWGuideCrabHowTo#Stageout_and_publication' |
| 18 |
|
self.dataPub_faq = 'https://twiki.cern.ch/twiki/bin/view/CMS/SWGuideCrabForPublication' |
| 19 |
|
|
| 20 |
|
self.usePhedex = True |
| 59 |
|
#check if using "private" Storage |
| 60 |
|
if not self.node : |
| 61 |
|
msg = 'Please specify the storage_element name in your crab.cfg section [USER].\n' |
| 62 |
< |
msg +='\tFor further information please visit : %s'%stage_out_faq |
| 62 |
> |
msg +='\tFor further information please visit : %s'%self.stage_out_faq |
| 63 |
|
raise CrabException(msg) |
| 64 |
|
if (self.node.find('T1_') + self.node.find('T2_')+self.node.find('T3_')) == -3: self.usePhedex = False |
| 65 |
|
|
| 66 |
|
if not self.usePhedex and ( self.user_remote_dir == '' or self.user_se_path == '' ): |
| 67 |
< |
msg = 'You are asking to stage out without using CMS Storage Name convention. In this case you \n' |
| 68 |
< |
msg += '\t must specify both user_remote_dir and storage_path in the crab.cfg section [USER].\n ' |
| 69 |
< |
msg += '\t For further information please visit : \n\t%s'%stage_out_faq |
| 67 |
> |
####### FEDE FOR BUG 73010 ############ |
| 68 |
> |
msg = 'Error: you are asking to stage out without using CMS Storage Name convention. In this case you \n' |
| 69 |
> |
msg += ' must specify both user_remote_dir and storage_path in the crab.cfg section [USER].\n' |
| 70 |
> |
msg += ' For further information please visit : \n\t%s'%self.stage_out_faq |
| 71 |
> |
task = common._db.getTask() |
| 72 |
> |
add = '\n\n' |
| 73 |
> |
import shutil |
| 74 |
> |
try: |
| 75 |
> |
add += ' Task not correctly created: removing the working_dir ' + common.work_space._top_dir + ' \n' |
| 76 |
> |
shutil.rmtree(common.work_space._top_dir) |
| 77 |
> |
except OSError: |
| 78 |
> |
add += ' Warning: problems removing the working_dir ' + common.work_space._top_dir + ' \n' |
| 79 |
> |
add += ' Please remove it by hand' |
| 80 |
> |
msg += add |
| 81 |
|
raise CrabException(msg) |
| 82 |
+ |
######################################### |
| 83 |
|
|
| 84 |
|
self.forced_path = '/store/user/' |
| 85 |
|
if self.sched in ['CAF','LSF','PBS']: |
| 99 |
|
|
| 100 |
|
#extract the PFN for the given node,LFN,protocol |
| 101 |
|
endpoint = self.getStageoutPFN() |
| 89 |
– |
### FEDE added a check for the final / |
| 102 |
|
if ( endpoint[-1] != '/' ) : endpoint = endpoint + '/' |
| 91 |
– |
###################################### |
| 103 |
|
|
| 104 |
|
#extract SE name an SE_PATH (needed for publication) |
| 105 |
|
SE, SE_PATH, User = self.splitEndpoint(endpoint) |
| 112 |
|
''' |
| 113 |
|
SE = '' |
| 114 |
|
SE_PATH = '' |
| 115 |
< |
USER = '' |
| 115 |
> |
USER = getUserName() |
| 116 |
|
if self.usePhedex: |
| 117 |
|
if self.protocol == 'direct': |
| 118 |
|
query=endpoint |
| 120 |
|
SE = self.SE[self.sched] |
| 121 |
|
else: |
| 122 |
|
url = 'http://'+endpoint.split('://')[1] |
| 112 |
– |
# python > 2.4 |
| 113 |
– |
# SE = urlparse(url).hostname |
| 123 |
|
scheme, host, path, params, query, fragment = urlparse(url) |
| 115 |
– |
# SE = host.split(':')[0] |
| 124 |
|
SE = self.getAuthoritativeSE() |
| 125 |
|
SE_PATH = endpoint.split(host)[1] |
| 118 |
– |
USER = (query.split('user')[1]).split('/')[1] |
| 126 |
|
else: |
| 120 |
– |
#### to test ##### |
| 121 |
– |
# url = 'http://'+endpoint.split('://')[1] |
| 122 |
– |
# scheme, host, path, params, query, fragment = urlparse(url) |
| 123 |
– |
# SE = host.split(':')[0] |
| 124 |
– |
# SE_PATH = endpoint.split(host)[1] |
| 127 |
|
SE = self.node |
| 128 |
|
SE_PATH = self.user_se_path + self.user_remote_dir |
| 129 |
< |
if self.lfn.find('user'): |
| 128 |
< |
try: |
| 129 |
< |
USER = (self.lfn.split('user')[1]).split('/')[1] |
| 130 |
< |
except: |
| 131 |
< |
pass |
| 132 |
< |
if self.lfn.find('group'): |
| 129 |
> |
if self.lfn.find('group') != -1: |
| 130 |
|
try: |
| 131 |
|
USER = (self.lfn.split('group')[1]).split('/')[1] |
| 132 |
|
except: |
| 133 |
|
pass |
| 134 |
|
return SE, SE_PATH, USER |
| 138 |
– |
|
| 135 |
|
|
| 136 |
|
def getLFN(self): |
| 137 |
|
""" |
| 165 |
|
else: |
| 166 |
|
if self.sched in ['CAF','LSF']: l_User=True |
| 167 |
|
lfn = LFNBase(self.forced_path,self.user_remote_dir) |
| 168 |
+ |
if ( lfn[-1] != '/' ) : lfn = lfn + '/' |
| 169 |
|
return lfn |
| 170 |
|
|
| 171 |
|
def computePrimaryDataset(self): |
| 261 |
|
else: |
| 262 |
|
stageoutpfn = 'srm://'+self.node+':'+self.user_port+self.user_se_path+self.lfn |
| 263 |
|
|
| 264 |
+ |
if ( stageoutpfn[-1] != '/' ) : stageoutpfn = stageoutpfn + '/' |
| 265 |
|
return stageoutpfn |
| 266 |
|
|
| 267 |
|
def getAuthoritativeSE(self): |
