Package Products :: Package ZenUtils :: Module ProcessQueue
[hide private]
[frames] | no frames]

Module ProcessQueue

source code

Classes [hide private]
QueueStopped
ProcessQueue
Ansynchronously run processes.
_ProcessQueueProtocol
For interal use by ProcessQueue Protocol to run processes in ProcessQueue.
_ProcessQueueProtocolDecorator
For interal use by ProcessQueue Wraps an existing ProcessProtocol so that it can be run in a ProcessQueue
TimeoutError
Error for a defered call taking too long to complete
Functions [hide private]
 
createTimeout(deferred, seconds, obj)
Cause an error on a deferred when it is taking too long to complete.
source code
Variables [hide private]
  log = logging.getLogger("zen.processqueue")
Function Details [hide private]

createTimeout(deferred, seconds, obj)

source code 

Cause an error on a deferred when it is taking too long to complete.

Parameters:
  • deferred (Deferred) - deferred to monitor for callback/errback
  • seconds (int) - Time to wait for a callback/errback on the deferred
  • obj (anything)