def send_job_complete(self, current_job, data, poll_timeout=None):
    current_handler = self._get_handler_for_job(current_job)
    current_handler.send_job_complete(current_job, data=data)
    self.wait_until_updates_sent([current_job], poll_timeout=poll_timeout)
def send_job_complete(self, current_job, data, poll_timeout=None):
    current_handler = self._get_handler_for_job(current_job)
    current_handler.send_job_complete(current_job, data=data)
    self.wait_until_updates_sent([current_job], poll_timeout=poll_timeout)