113 |
|
msg += "Total Jobs : %s\n" % len(task.getJobs()) |
114 |
|
msg += "Luminosity section summary file: %s\n" % lumiFilename |
115 |
|
list_ID={} |
116 |
< |
task = common.scheduler.queryEverything(task['id']) |
116 |
> |
|
117 |
> |
# TEMPORARY by Fabio, to be removed |
118 |
> |
# avoid clashes between glite_slc5 and glite schedulers when a server is used |
119 |
> |
# otherwise, -report with a server requires a local scheduler |
120 |
> |
if self.cfg_params.get('CRAB.server_name', None) is None: |
121 |
> |
common.logger.debug( "Reporter updating task status") |
122 |
> |
task = common.scheduler.queryEverything(task['id']) |
123 |
> |
|
124 |
|
for st in possible_status: |
125 |
|
list_ID = common._db.queryAttrRunJob({'statusScheduler':st},'jobId') |
126 |
|
if (len(list_ID)>0): |