| 89 |
|
""" |
| 90 |
|
Contact DBS |
| 91 |
|
""" |
| 92 |
– |
|
| 92 |
|
## get DBS URL |
| 93 |
< |
dbs_url="http://cmsdbsprod.cern.ch/cms_dbs_prod_global/servlet/DBSServlet" |
| 94 |
< |
if (self.cfg_params.has_key('CMSSW.dbs_url')): |
| 95 |
< |
dbs_url=self.cfg_params['CMSSW.dbs_url'] |
| 93 |
> |
global_url="http://cmsdbsprod.cern.ch/cms_dbs_prod_global/servlet/DBSServlet" |
| 94 |
> |
caf_url = "http://cmsdbsprod.cern.ch/cms_dbs_caf_analysis_01/servlet/DBSServlet" |
| 95 |
> |
dbs_url_map = {'glite': global_url, |
| 96 |
> |
'glitecoll':global_url,\ |
| 97 |
> |
'condor': global_url,\ |
| 98 |
> |
'condor_g': global_url,\ |
| 99 |
> |
'glidein': global_url,\ |
| 100 |
> |
'lsf': global_url,\ |
| 101 |
> |
'caf': caf_url,\ |
| 102 |
> |
'sge': global_url |
| 103 |
> |
} |
| 104 |
|
|
| 105 |
+ |
dbs_url_default = dbs_url_map[(common.scheduler.name()).lower()] |
| 106 |
+ |
dbs_url= self.cfg_params.get('CMSSW.dbs_url', dbs_url_default) |
| 107 |
|
common.logger.debug(3,"Accessing DBS at: "+dbs_url) |
| 108 |
|
|
| 109 |
|
## check if runs are selected |
| 125 |
|
fileBlocks_FileName = os.path.abspath(self.cfg_params.get('CMSSW.fileblocks_file',defaultName)) |
| 126 |
|
|
| 127 |
|
api = DBSAPI.dbsApi.DbsApi(args) |
| 128 |
+ |
allowedRetriveValue = ['retrive_parent', |
| 129 |
+ |
'retrive_block', |
| 130 |
+ |
'retrive_lumi', |
| 131 |
+ |
'retrive_run' |
| 132 |
+ |
] |
| 133 |
|
try: |
| 134 |
|
if len(runselection) <= 0 : |
| 135 |
|
if useParent: |
| 122 |
– |
allowedRetriveValue = ['retrive_parent', |
| 123 |
– |
'retrive_block', |
| 124 |
– |
'retrive_lumi', |
| 125 |
– |
'retrive_run' |
| 126 |
– |
] |
| 136 |
|
files = api.listFiles(path=self.datasetPath, retriveList=allowedRetriveValue) |
| 137 |
|
common.logger.debug(5,"Set of input parameters used for DBS query : \n"+str(allowedRetriveValue)) |
| 138 |
|
common.logger.write("Set of input parameters used for DBS query : \n"+str(allowedRetriveValue)) |
