pandajedi/jeditest/resubmitTaskParam.py

0001 import sys
0002
0003 from taskbuffer.Initializer import initializer
0004
0005 from pandajedi.jedicore import JediTaskBuffer
0006
0007 jediTaskID = sys.argv[1]
0008
0009 # initialize DB using dummy connection
0010 initializer.init()
0011
0012
0013 taskBuffer = JediTaskBuffer.JediTaskBuffer(None)
0014 proxy = taskBuffer.proxyPool.getProxy()
0015
0016 s, o = proxy.getClobObj("select task_param from atlas_deft.deft_task where task_id=:task_id", {":task_id": jediTaskID})
0017
0018 taskParamStr = o[0][0]
0019
0020 proxy.insertTaskParams_JEDI(None, taskParamStr)