def send_job_exception(self, current_job, data, poll_timeout=None):
    'Removes a job from the queue if its backgrounded'
    current_handler = self._get_handler_for_job(current_job)
    current_handler.send_job_exception(current_job, data=data)
    current_handler.send_job_failure(current_job)
    self.wait_until_updates_sent([current_job], poll_timeout=poll_timeout)
Removes a job from the queue if its backgrounded
def send_job_exception(self, current_job, data, poll_timeout=None):
    
    current_handler = self._get_handler_for_job(current_job)
    current_handler.send_job_exception(current_job, data=data)
    current_handler.send_job_failure(current_job)
    self.wait_until_updates_sent([current_job], poll_timeout=poll_timeout)