pandaharvester/harvestercore/panda_queue_spec.py

0001 """
0002 Panda Queue class
0003
0004 """
0005
0006 from .spec_base import SpecBase
0007
0008
0009 class PandaQueueSpec(SpecBase):
0010     # attributes
0011     attributesWithTypes = (
0012         "queueName:text / index",
0013         "nQueueLimitJob:integer",
0014         "nQueueLimitWorker:integer",
0015         "maxWorkers:integer",
0016         "jobFetchTime:timestamp / index",
0017         "submitTime:timestamp / index",
0018         "lockedBy:text",
0019         "siteName:text / index",
0020         "jobType:text",
0021         "resourceType:text",
0022         "nNewWorkers:integer",
0023         "uniqueName:text primary key",
0024         "nQueueLimitJobRatio:integer",
0025         "nQueueLimitJobMax:integer",
0026         "nQueueLimitJobMin:integer",
0027         "nQueueLimitWorkerRatio:integer",
0028         "nQueueLimitWorkerMax:integer",
0029         "nQueueLimitWorkerMin:integer",
0030     )
0031
0032     # catchall resource type
0033     RT_catchall = "ANY"
0034     JT_catchall = "ANY"
0035     # constructor
0036
0037     def __init__(self):
0038         SpecBase.__init__(self)