|
| str | taskman.__author__ = 'Juerg Beringer' |
| str | taskman.__version__ = 'taskman.py atlas/athena' |
| str | taskman.__usage__ |
| | taskman.parser = OptionParser(usage=__usage__, version=__version__) |
| | taskman.dest |
| | taskman.action |
| | taskman.default |
| | taskman.False |
| | taskman.help |
| | taskman.None |
| | taskman.options |
| | taskman.args |
| | taskman.cmd = args[0] |
| | taskman.cmdargs = args[1:] |
| | taskman.proddir = options.proddir |
| | taskman.dbtype |
| | taskman.dbname |
| | taskman.a = raw_input('\nRECREATING TASK DATABASE SCHEMA - ANY EXISTING DATA WILL BE ERASED!\n\nARE YOU REALLY ABSOLUTELY SURE [n] ? ') |
| | taskman.dbconn |
| | taskman.createDatabase |
| | taskman.dbfile |
| | taskman.status = TaskManager.StatusCodes.get(statusName) |
| | taskman.output |
| int | taskman.nDuplicates = 0 |
| | taskman.qual = [] |
| | taskman.dsname = cmdargs[0] |
| | taskman.taskname = cmdargs[1] |
| | taskman.taskList |
| | taskman.taskEntry = taskman.getTaskDict(t[0], t[1]) |
| | taskman.taskpath = os.path.join(proddir, dsname, taskname) |
| list | taskman.dirs = [] |
| | taskman.dsName |
| | taskman.taskName |
| | taskman.nDefined |
| | taskman.configFile = glob.glob(os.path.join(proddir, dsName, taskName, '*', '*.config.py')) |
| | taskman.mtime = os.stat(configFile[0])[stat.ST_MTIME] |
| dict | taskman.config = {} |
| dict | taskman.template = config['jobConfig']['joboptionpath'] |
| dict | taskman.release = config['jobConfig']['release'] |
| dict | taskman.taskpostprocsteps = config['jobConfig']['taskpostprocsteps'] |
| dict | taskman.comment = config['jobConfig']['comment'] + ' (rebuilt from config file)' |
| | taskman.createdTime |
| | taskman.createdUser |
| | taskman.createdHost |
| | taskman.fromDbconn = cmdargs[0] |
| | taskman.wildcards = string.maketrans('*?', '%_') |
| | taskman.destDbtype |
| | taskman.destDbname |
| | taskman.fromDbtype |
| | taskman.fromDbname |
| int | taskman.nImported = 0 |
| str | taskman.links = '' |
| | taskman.files = t.get('RESULTFILES','') |
| | taskman.summaryFiles = glob.glob('%s/%s/*beamspot.gif' % (dsname,taskname)) |
| | taskman.f = r.split('/')[-1] |
| str | taskman.pdf = f[:-3]+'pdf' |
| | taskman.monitoringFiles = glob.glob('%s/%s/*beamspotmon.gif' % (dsname,taskname)) |
| str | taskman.fieldNameString = '' |
| list | taskman.params = [] |
| | taskman.newFieldName = fieldName |
| list | taskman.q = [ 'insert into TASKS (%s) values (' % fieldNameString ] |
| | taskman.statusName = cmdargs[2].upper() |
| int | taskman.n = 0 |
| | taskman.fieldName = cmdargs[2].upper() |
| | taskman.fieldValue = cmdargs[3] |
| | taskman.requireSingleTask |
| | taskman.confirmWithUser |
| | taskman.addWildCards |
| | taskman.batch |
| | taskman.True |
| str | taskman.dir = '/'.join([proddir,dsname,task]) |
| | taskman.earliestUpdateTime = time.time()-float(args[1]) |
| | taskman.dsWidth = len(max([t['DSNAME'] for t in taskList],key=len)) |
| | taskman.taskWidth = len(max([t['TASKNAME'] for t in taskList],key=len)) |
| | taskman.statusWidth = len(max([t['STATUS'] for t in taskList],key=len)) |
| str | taskman.bodyFormat = '%%(DSNAME)%ss %%(TASKNAME)%ss %%(STATUS)%ss' %(dsWidth, taskWidth, statusWidth) |
| str | taskman.mailBody = 'The following %s tasks have reported failures' % len(taskList) |
| | taskman.hours = round(float(args[1])/3600.) |
| int | taskman.stat = os.system('source /afs/cern.ch/user/a/atlidbs/cron/mailwrapper; mailwrapper "[atlidbs] %s tasks report failures" "%s"' %(len(taskList), mailBody)) >> 8 |
| | taskman.taskman = getTaskManager() |
| | taskman.debug |
1.14.0