def _get_handler_for_job(self, current_job):
    return self.connection_to_handler_map[current_job.connection]
def _get_handler_for_job(self, current_job):
    return self.connection_to_handler_map[current_job.connection]