#!/usr/bin/env python # -*- coding: utf-8 -*- # @Author: Elena Graverini # @Date: 2016-01-15 14:04:25 # @Last Modified by: Elena Graverini # @Last Modified time: 2016-01-15 14:04:45 gridProxy.renew() myjobs = jobs.select(64, 83) stuckSubjobs = 0 failedSubjobs = 0 totalSubJobs = 0 sitesToBan = ['LCG.GRIDKA.de', 'LCG.IN2P3.fr', 'LCG.PIC.es', 'LCG.NIKHEF.nl', 'LCG.SARA.nl', 'LCG.RAL.uk'] for (index, j) in enumerate(myjobs): for sj in j.subjobs: totalSubJobs += 1 if (sj.status == "new"): queues.add(sj.submit) stuckSubjobs += 1 if (sj.status == "failed"): sj.backend.reset() sj.backend.settings['BannedSites'] = sitesToBan queues.add(sj.resubmit) failedSubjobs += 1 print '%s new subjobs submitted, %s failed subjobs resubmitted.' % (stuckSubjobs,failedSubjobs)