pandaserver/test/boostPrio.py

0001 import sys
0002
0003 # password
0004 from pandaserver.config import panda_config
0005 from pandaserver.taskbuffer.OraDBProxy import DBProxy
0006
0007 proxyS = DBProxy()
0008 proxyS.connect(panda_config.dbhost, panda_config.dbpasswd, panda_config.dbuser, panda_config.dbname)
0009
0010 varMap = {}
0011 varMap[":prodSourceLabel"] = "managed"
0012 varMap[":taskID"] = sys.argv[1]
0013 varMap[":prio"] = sys.argv[2]
0014 sql = "UPDATE %s SET currentPriority=currentPriority+:prio WHERE prodSourceLabel=:prodSourceLabel AND taskID=:taskID"
0015 for table in [
0016     "ATLAS_PANDA.jobsActive4",
0017     "ATLAS_PANDA.jobsDefined4",
0018 ]:
0019     status, res = proxyS.querySQLS(sql % table, varMap)