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

Comparing COMP/CRAB/python/SchedulerGlite.py (file contents):
Revision 1.7 by slacapra, Tue Oct 17 09:52:57 2006 UTC vs.
Revision 1.12 by slacapra, Mon Feb 26 12:02:25 2007 UTC

# Line 44 | Line 44 | class SchedulerGlite(SchedulerEdg):
44    
45          req = ''
46          req = req + jbt.getRequirements()
47 <    
47 >  
48 >  
49          if self.EDG_requirements:
50              if (req == ' '):
51                  req = req + self.EDG_requirements
# Line 55 | Line 56 | class SchedulerGlite(SchedulerEdg):
56              for i in range(len(ce_white_list)):
57                  if i == 0:
58                      if (req == ' '):
59 <                        req = req + '((RegExp("' + ce_white_list[i] + '", other.GlueCEUniqueId))'
59 >                        req = req + '((RegExp("' + string.strip(ce_white_list[i]) + '", other.GlueCEUniqueId))'
60                      else:
61 <                        req = req +  ' && ((RegExp("' + ce_white_list[i] + '", other.GlueCEUniqueId))'
61 >                        req = req +  ' && ((RegExp("' + string.strip(ce_white_list[i]) + '", other.GlueCEUniqueId))'
62                      pass
63                  else:
64 <                    req = req +  ' || (RegExp("' + ce_white_list[i] + '", other.GlueCEUniqueId))'
64 >                    req = req +  ' || (RegExp("' + string.strip(ce_white_list[i]) + '", other.GlueCEUniqueId))'
65              req = req + ')'
66          
67          if self.EDG_ce_black_list:
68              ce_black_list = string.split(self.EDG_ce_black_list,',')
69              for ce in ce_black_list:
70                  if (req == ' '):
71 <                    req = req + '(!RegExp("' + ce + '", other.GlueCEUniqueId))'
71 >                    req = req + '(!RegExp("' + string.strip(ce) + '", other.GlueCEUniqueId))'
72                  else:
73 <                    req = req +  ' && (!RegExp("' + ce + '", other.GlueCEUniqueId))'
73 >                    req = req +  ' && (!RegExp("' + string.strip(ce) + '", other.GlueCEUniqueId))'
74                  pass
75 +        
76 +
77          if self.EDG_clock_time:
78              if (req == ' '):
79                  req = req + 'other.GlueCEPolicyMaxWallClockTime>='+self.EDG_clock_time
# Line 90 | Line 93 | class SchedulerGlite(SchedulerEdg):
93              itr4=self.findSites_(first[i])
94              reqSites=''
95              reqtmp=[]  
93 –            j = 0
96              concString = '||'
97              for arg in itr4:
98                  #############
99                  # MC Changed matching syntax to avoid gang matching
100                  #############
101                  reqtmp.append(' Member("'+arg+'" , other.GlueCESEBindGroupSEUniqueID) ')
102 <            if len(reqtmp): reqSites = reqSites + " && (" + concString.join(reqtmp) + ')'
103 <            reqSites = reqSites + ';\n'
102 >            if len(reqtmp): reqSites = reqSites + " && (" + concString.join(reqtmp)  
103 >            # requirement added to skip gliteCE
104 >            reqSites = reqSites + '&& (!RegExp("blah", other.GlueCEUniqueId)));\n'
105              param_file.write('Requirements = ' + req + reqSites )
106    
107              if (self.rb_param_file != ''):
# Line 243 | Line 246 | class SchedulerGlite(SchedulerEdg):
246          retrieve the logging info from logging and bookkeeping and return it
247          """
248          self.checkProxy()
249 <        cmd = 'glite-job-logging-info -v 2 ' + id
249 >        cmd = 'glite-job-logging-info -v 3 ' + id
250          cmd_out = runCommand(cmd)
251          return cmd_out
252  

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines