Main queue object (thread safe).
Contains two internal queues: one for actually holding requests, and
one for holding the tasks that are currently being processed. This way,
if a task fails to process we can cycle it back into the requests queue a
few times to see if the error was transient.
|
|
__init__(self)
x.__init__(...) initializes x; see x.__class__.__doc__ for signature |
source code
|
|
|
|
|
|
|
putTask(self,
request)
Puts a model into the queue for worker processing. |
source code
|
|
|
|
putTaskHead(self,
request)
Puts a model into queue at the head (useful for peeking). |
source code
|
|
|
|
putProcessingTask(self,
task)
Puts a model into the queue for worker processing. |
source code
|
|
|
|
pullNextVersioned(self,
modelVersions)
Pulls the next model from the worker queue that matches versions. |
source code
|
|
|
|
pullNextTask(self)
Pulls a model from the worker queue. |
source code
|
|
|
|
touchProcessingTaskById(self,
taskId)
Update timestamp on a task that is currently processing. |
source code
|
|
|
|
|
|
|
pullProcessingTasksOlderThan(self,
oldTime)
Pulls tasks out of the processing queue that are stale. |
source code
|
|
|
|
|
|
|
|
|
Inherited from object:
__delattr__,
__format__,
__getattribute__,
__hash__,
__new__,
__reduce__,
__reduce_ex__,
__repr__,
__setattr__,
__sizeof__,
__str__,
__subclasshook__
|