Show
Ignore:
Timestamp:
02/22/08 22:41:33 (9 months ago)
Author:
edsuom
Message:

Worker specialties, improved timouts

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • projects/AsynQueue/trunk/asynqueue/base.py

    r112 r126  
    2626from zope.interface import implements 
    2727from twisted.python import failure 
    28 from twisted.internet import defer, reactor, interfaces 
     28from twisted.internet import reactor, interfaces, defer 
     29# Use C Deferreds if possible, for efficiency 
     30try: 
     31    from twisted.internet import cdefer 
     32except: 
     33    pass 
     34else: 
     35    defer.Deferred = cdefer.Deferred 
    2936 
    3037import tasks 
    …… 
    328335          task has been queued up. 
    329336 
     337        @keyword timeout: A timeout interval in seconds from when a worker gets 
     338          a task assignment for the call, after which the call will be retried. 
     339 
    330340        """ 
    331341        def oneLessPending(result): 
    …… 
    351361        niceness = kw.pop('niceness', 0) 
    352362        series = kw.pop('series', None) 
    353         task = self._taskFactory.new(func, args, kw, niceness, series) 
     363        timeout = kw.pop('timeout', None) 
     364        task = self._taskFactory.new(func, args, kw, niceness, series, timeout) 
    354365        if kw.pop('doNext', False): 
    355366            task.priority = -1000000