| 92 |
|
except KeyError: |
| 93 |
|
dbs_url="http://cmsdbsprod.cern.ch/cms_dbs_prod_global/servlet/DBSServlet" |
| 94 |
|
|
| 95 |
< |
## get DBS URL |
| 96 |
< |
try: |
| 97 |
< |
dbs_version=self.cfg_params['CMSSW.dbs_version'] |
| 98 |
< |
except KeyError: |
| 99 |
< |
dbs_version="v00_00_06" |
| 100 |
< |
|
| 101 |
< |
common.logger.debug(3,"Accessing DBS at: "+dbs_url+" with version: "+dbs_version) |
| 95 |
> |
common.logger.debug(3,"Accessing DBS at: "+dbs_url) |
| 96 |
|
|
| 97 |
|
|
| 98 |
|
## service API |
| 99 |
|
args = {} |
| 100 |
|
args['url'] = dbs_url |
| 107 |
– |
args['version'] = dbs_version |
| 101 |
|
args['level'] = 'CRITICAL' |
| 102 |
|
|
| 103 |
|
api = DBSAPI.dbsApi.DbsApi(args) |
| 104 |
|
try: |
| 105 |
< |
files = api.listFiles(self.datasetPath) |
| 105 |
> |
files = api.listDatasetFiles(self.datasetPath) |
| 106 |
|
except DbsBadRequest, msg: |
| 107 |
|
raise DataDiscoveryError_DBS2(msg) |
| 108 |
|
except DBSError_DBS2, msg: |
| 109 |
|
raise DataDiscoveryError_DBS2(msg) |
| 110 |
< |
|
| 110 |
> |
|
| 111 |
|
# parse files and fill arrays |
| 112 |
|
for file in files : |
| 113 |
|
filename = file['LogicalFileName'] |
