| 90 |
|
try: |
| 91 |
|
dbs_url=self.cfg_params['CMSSW.dbs_url'] |
| 92 |
|
except KeyError: |
| 93 |
< |
dbs_url="http://cmsdoc.cern.ch/cms/test/aprom/DBS/CGIServer/prodquery" |
| 93 |
> |
dbs_url="http://cmsdbsprod.cern.ch/cms_dbs_prod_global/servlet/DBSServlet" |
| 94 |
> |
|
| 95 |
> |
common.logger.debug(3,"Accessing DBS at: "+dbs_url) |
| 96 |
> |
|
| 97 |
|
|
| 98 |
|
## service API |
| 99 |
|
args = {} |
| 100 |
< |
args['url']=dbs_url |
| 101 |
< |
|
| 99 |
< |
common.logger.debug(3,"Accessing DBS at: "+dbs_url) |
| 100 |
> |
args['url'] = dbs_url |
| 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'] |
| 132 |
|
# total number of events |
| 133 |
|
self.maxEvents += events |
| 134 |
|
|
| 135 |
+ |
for block in self.eventsPerBlock.keys() : |
| 136 |
+ |
common.logger.debug(6,"DBSInfo: total nevts %i in block %s "%(self.eventsPerBlock[block],block)) |
| 137 |
+ |
|
| 138 |
|
if len(self.eventsPerBlock) <= 0: |
| 139 |
|
raise NotExistingDatasetError_DBS2 (("\nNo data for %s in DBS\nPlease check" |
| 140 |
|
+ " dataset path variables in crab.cfg") |
