ViewVC Help
View File | Revision Log | Show Annotations | Root Listing
root/cvsroot/COMP/CRAB/python/JdlWriter.py
(Generate patch)

Comparing COMP/CRAB/python/JdlWriter.py (file contents):
Revision 1.2 by slacapra, Thu Jun 5 16:35:32 2008 UTC vs.
Revision 1.3 by slacapra, Thu Jan 8 15:12:30 2009 UTC

# Line 9 | Line 9 | class JdlWriter( Actor ):
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):
# Line 42 | Line 47 | class JdlWriter( Actor ):
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:
# Line 55 | Line 64 | class JdlWriter( Actor ):
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

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines