cgearman.py

from gearman import GearmanWorker
from traceback import format_exception, print_exception
from StringIO import StringIO
import logging

class ExceptionalGearmanWorker(GearmanWorker):
        
    def on_job_exception(self, current_job, exception_tuple):
        """ Override the default on_job_exception handler to log an error
        to the console.
        """
        sbuffer = StringIO()
        print_exception(exception_tuple[0], exception_tuple[1],
                        exception_tuple[2], file=sbuffer)
        logging.error(sbuffer.getvalue())
        return super(ExceptionalGearmanWorker, self).on_job_exception(current_job, exception_tuple)