def handle_error(self, current_connection):
    'If we discover that a connection has a problem, we better release\n        the job lock'
    current_handler = self.connection_to_handler_map.get(current_connection)
    if current_handler:
        self.set_job_lock(current_handler, lock=False)
    super(GearmanWorker, self).handle_error(current_connection)
If we discover that a connection has a problem, we better release
the job lock
def handle_error(self, current_connection):
    'If we discover that a connection has a problem, we better release\n        the job lock'
    current_handler = self.connection_to_handler_map.get(current_connection)
    if current_handler:
        self.set_job_lock(current_handler, lock=False)
    super(GearmanWorker, self).handle_error(current_connection)