'Override to handle cases where a work item causes an exception
work is the problematic work item
return True to keep going'

def _on_exception(self, exception, work):

    self.log.error('While    executing    %s...', work)
    self.log.exception(exception)
    return True
