pandajedi/jeditest/workQueueTest.py

0001 from taskbuffer.Initializer import initializer
0002
0003 from pandajedi.jedicore import JediTaskBuffer
0004
0005 # initialize DB using dummy connection
0006 initializer.init()
0007
0008 taskBuffer = JediTaskBuffer.JediTaskBuffer(None)
0009 proxy = taskBuffer.proxyPool.getProxy()
0010 proxy.refreshWorkQueueMap()
0011
0012 # print proxy.workQueueMap.dump()
0013 """
0014 print proxy.workQueueMap.getQueueWithSelParams('atlas','managed',
0015                                   prodSourceLabel='managed',
0016                                   workingGroup='GP_Top')[0].queue_name
0017 print proxy.workQueueMap.getQueueWithSelParams('atlas','managed',
0018                                   prodSourceLabel='managed',
0019                                   workingGroup='AP_Top',
0020                                   processingType='simul')[0].queue_name
0021 print proxy.workQueueMap.getShares('atlas','managed',[1,2,7,8])
0022 """