def _exception_handler(request, exc_info):
- """Rudimentary exception handler, simply logs and moves on."""
+ """Rudimentary exception handler, simply logs and moves on. If there's no
+ tuple, it means something went really wrong. Critically log and exit."""
if not isinstance(exc_info, tuple):
# Something is seriously wrong...
logger.warn("**** Exception occured in request #%s: %s" % \
self.daemon = True #daemon thread..important!
self.pool = ThreadPool(self.threads)
- def enqueue(self, payload, timeout, callback=None, exc_callback=_infodump):
#create the worker request
request = WorkRequest(_ride_the_toad,
- time.sleep(0.5) #configure
+ time.sleep(0.5) #configure