9 |
|
def __init__(self, cfg_params, jobs): |
10 |
|
self.cfg_params = cfg_params |
11 |
|
self.nj_list = jobs |
12 |
+ |
from WMCore.SiteScreening.BlackWhiteListParser import SEBlackWhiteListParser |
13 |
+ |
seWhiteList = cfg_params.get('EDG.se_white_list',[]) |
14 |
+ |
seBlackList = cfg_params.get('EDG.se_black_list',[]) |
15 |
+ |
self.blackWhiteListParser = SEBlackWhiteListParser(seWhiteList, seBlackList, common.logger) |
16 |
+ |
|
17 |
|
return |
18 |
|
|
19 |
|
def run(self): |
47 |
|
all_jobs=[] |
48 |
|
count=0 |
49 |
|
for distDest in distinct_dests: |
50 |
+ |
dest = self.blackWhiteListParser.cleanForBlackWhiteList(distDest) |
51 |
+ |
if not dest: |
52 |
+ |
common.logger.message('No destination available: will not create jdl \n' ) |
53 |
+ |
continue |
54 |
|
all_jobs.append(common._db.queryAttrJob({'dlsDestination':distDest},'jobId')) |
55 |
|
sub_jobs_temp=[] |
56 |
|
for i in self.nj_list: |
64 |
|
""" |
65 |
|
Materialize JDL into file |
66 |
|
""" |
67 |
+ |
if len(list)==0: |
68 |
+ |
common.logger.message('No destination available for any job: will not create jdl \n' ) |
69 |
+ |
|
70 |
|
task = common._db.getTask() |
71 |
|
c1 = 1 |
72 |
|
c2 = 1 |